[INFO] cloning repository https://github.com/Rustixir/tokio_sky
[INFO] running `Command { std: "git" "-c" "credential.helper=" "-c" "credential.helper=/workspace/cargo-home/bin/git-credential-null" "clone" "--bare" "https://github.com/Rustixir/tokio_sky" "/workspace/cache/git-repos/https%3A%2F%2Fgithub.com%2FRustixir%2Ftokio_sky", kill_on_drop: false }`
[INFO] [stderr] Cloning into bare repository '/workspace/cache/git-repos/https%3A%2F%2Fgithub.com%2FRustixir%2Ftokio_sky'...
[INFO] running `Command { std: "git" "rev-parse" "HEAD", kill_on_drop: false }`
[INFO] [stdout] aa58347b963c17870c401c00d4a104c6b3bee6f6
[INFO] checking Rustixir/tokio_sky against master#9610dfe5a9a731ced1ea4923ecbd0c57fe367898 for beta-170-4
[INFO] running `Command { std: "git" "clone" "/workspace/cache/git-repos/https%3A%2F%2Fgithub.com%2FRustixir%2Ftokio_sky" "/workspace/builds/worker-0-tc1/source", kill_on_drop: false }`
[INFO] [stderr] Cloning into '/workspace/builds/worker-0-tc1/source'...
[INFO] [stderr] done.
[INFO] validating manifest of git repo https://github.com/Rustixir/tokio_sky on toolchain 9610dfe5a9a731ced1ea4923ecbd0c57fe367898
[INFO] running `Command { std: CARGO_HOME="/workspace/cargo-home" RUSTUP_HOME="/workspace/rustup-home" "/workspace/cargo-home/bin/cargo" "+9610dfe5a9a731ced1ea4923ecbd0c57fe367898" "metadata" "--manifest-path" "Cargo.toml" "--no-deps", kill_on_drop: false }`
[INFO] started tweaking git repo https://github.com/Rustixir/tokio_sky
[INFO] finished tweaking git repo https://github.com/Rustixir/tokio_sky
[INFO] tweaked toml for git repo https://github.com/Rustixir/tokio_sky written to /workspace/builds/worker-0-tc1/source/Cargo.toml
[INFO] crate git repo https://github.com/Rustixir/tokio_sky already has a lockfile, it will not be regenerated
[INFO] running `Command { std: CARGO_HOME="/workspace/cargo-home" RUSTUP_HOME="/workspace/rustup-home" "/workspace/cargo-home/bin/cargo" "+9610dfe5a9a731ced1ea4923ecbd0c57fe367898" "fetch" "--manifest-path" "Cargo.toml", kill_on_drop: false }`
[INFO] [stderr]     Updating crates.io index
[INFO] [stderr]  Downloading crates ...
[INFO] [stderr]   Downloaded hashring v0.3.0
[INFO] [stderr]   Downloaded pulsar v4.1.1
[INFO] [stderr]   Downloaded libz-sys v1.1.6
[INFO] [stderr]   Downloaded tokio v1.18.1
[INFO] running `Command { std: "docker" "create" "-v" "/var/lib/crater-agent-workspace/builds/worker-0-tc1/target:/opt/rustwide/target:rw,Z" "-v" "/var/lib/crater-agent-workspace/builds/worker-0-tc1/source:/opt/rustwide/workdir:ro,Z" "-v" "/var/lib/crater-agent-workspace/cargo-home:/opt/rustwide/cargo-home:ro,Z" "-v" "/var/lib/crater-agent-workspace/rustup-home:/opt/rustwide/rustup-home:ro,Z" "-e" "SOURCE_DIR=/opt/rustwide/workdir" "-e" "CARGO_TARGET_DIR=/opt/rustwide/target" "-e" "CARGO_HOME=/opt/rustwide/cargo-home" "-e" "RUSTUP_HOME=/opt/rustwide/rustup-home" "-w" "/opt/rustwide/workdir" "-m" "1610612736" "--user" "0:0" "--network" "none" "ghcr.io/rust-lang/crates-build-env/linux@sha256:19e73879b68f455e41552ea35293514db52ea292d993f571636dbffedb77a1ee" "/opt/rustwide/cargo-home/bin/cargo" "+9610dfe5a9a731ced1ea4923ecbd0c57fe367898" "metadata" "--no-deps" "--format-version=1", kill_on_drop: false }`
[INFO] [stdout] b47f68705a4f8f239bd1555df83a852c88f890330bbb1b3ca97dd9e95e2f60e8
[INFO] running `Command { std: "docker" "start" "-a" "b47f68705a4f8f239bd1555df83a852c88f890330bbb1b3ca97dd9e95e2f60e8", kill_on_drop: false }`
[INFO] running `Command { std: "docker" "inspect" "b47f68705a4f8f239bd1555df83a852c88f890330bbb1b3ca97dd9e95e2f60e8", kill_on_drop: false }`
[INFO] running `Command { std: "docker" "rm" "-f" "b47f68705a4f8f239bd1555df83a852c88f890330bbb1b3ca97dd9e95e2f60e8", kill_on_drop: false }`
[INFO] [stdout] b47f68705a4f8f239bd1555df83a852c88f890330bbb1b3ca97dd9e95e2f60e8
[INFO] running `Command { std: "docker" "create" "-v" "/var/lib/crater-agent-workspace/builds/worker-0-tc1/target:/opt/rustwide/target:rw,Z" "-v" "/var/lib/crater-agent-workspace/builds/worker-0-tc1/source:/opt/rustwide/workdir:ro,Z" "-v" "/var/lib/crater-agent-workspace/cargo-home:/opt/rustwide/cargo-home:ro,Z" "-v" "/var/lib/crater-agent-workspace/rustup-home:/opt/rustwide/rustup-home:ro,Z" "-e" "SOURCE_DIR=/opt/rustwide/workdir" "-e" "CARGO_TARGET_DIR=/opt/rustwide/target" "-e" "CARGO_INCREMENTAL=0" "-e" "RUST_BACKTRACE=full" "-e" "RUSTFLAGS=--cap-lints=forbid" "-e" "RUSTDOCFLAGS=--cap-lints=forbid" "-e" "CARGO_HOME=/opt/rustwide/cargo-home" "-e" "RUSTUP_HOME=/opt/rustwide/rustup-home" "-w" "/opt/rustwide/workdir" "-m" "1610612736" "--user" "0:0" "--network" "none" "ghcr.io/rust-lang/crates-build-env/linux@sha256:19e73879b68f455e41552ea35293514db52ea292d993f571636dbffedb77a1ee" "/opt/rustwide/cargo-home/bin/cargo" "+9610dfe5a9a731ced1ea4923ecbd0c57fe367898" "check" "--frozen" "--all" "--all-targets" "--message-format=json", kill_on_drop: false }`
[INFO] [stdout] 62d159b0ba12fbe8c5e03852b0110d03dbf5aa94222d0915e57990d6ff2894cc
[INFO] running `Command { std: "docker" "start" "-a" "62d159b0ba12fbe8c5e03852b0110d03dbf5aa94222d0915e57990d6ff2894cc", kill_on_drop: false }`
[INFO] [stderr]    Compiling syn v1.0.92
[INFO] [stderr]    Compiling libc v0.2.125
[INFO] [stderr]    Compiling async-trait v0.1.53
[INFO] [stderr]     Checking siphasher v0.3.10
[INFO] [stderr]    Compiling proc-macro2 v1.0.37
[INFO] [stderr]    Compiling indexmap v1.8.1
[INFO] [stderr]     Checking once_cell v1.10.0
[INFO] [stderr]     Checking hashring v0.3.0
[INFO] [stderr]    Compiling quote v1.0.18
[INFO] [stderr]     Checking num_cpus v1.13.1
[INFO] [stderr]    Compiling tokio-macros v1.7.0
[INFO] [stderr]     Checking tokio v1.18.1
[INFO] [stderr]     Checking tokio_sky v1.0.0 (/opt/rustwide/workdir)
[INFO] [stdout] warning: struct `Context` is never constructed
[INFO] [stdout]   --> src/producer.rs:42:12
[INFO] [stdout]    |
[INFO] [stdout] 42 | pub struct Context<T, Prod> 
[INFO] [stdout]    |            ^^^^^^^
[INFO] [stdout]    |
[INFO] [stdout]    = note: `#[warn(dead_code)]` on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: associated items `new` and `run` are never used
[INFO] [stdout]   --> src/producer.rs:57:12
[INFO] [stdout]    |
[INFO] [stdout] 51 | impl<T, Prod> Context<T, Prod> 
[INFO] [stdout]    | ------------------------------ associated items in this implementation
[INFO] [stdout] ...
[INFO] [stdout] 57 |     pub fn new(dispatcher: Dispatcher<T>,
[INFO] [stdout]    |            ^^^
[INFO] [stdout] ...
[INFO] [stdout] 78 |     pub fn run(mut self) {
[INFO] [stdout]    |            ^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: struct `Context` is never constructed
[INFO] [stdout]   --> src/batcher.rs:29:12
[INFO] [stdout]    |
[INFO] [stdout] 29 | pub struct Context<Input, Proc>
[INFO] [stdout]    |            ^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: associated items `new` and `run` are never used
[INFO] [stdout]   --> src/batcher.rs:48:12
[INFO] [stdout]    |
[INFO] [stdout] 42 | impl<Input, Proc> Context<Input, Proc> 
[INFO] [stdout]    | -------------------------------------- associated items in this implementation
[INFO] [stdout] ...
[INFO] [stdout] 48 |     pub fn new(recv: mpsc::Receiver<Input>,
[INFO] [stdout]    |            ^^^
[INFO] [stdout] ...
[INFO] [stdout] 64 |     pub fn run(mut self) {        
[INFO] [stdout]    |            ^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: struct `Context` is never constructed
[INFO] [stdout]   --> src/processor.rs:39:12
[INFO] [stdout]    |
[INFO] [stdout] 39 | pub struct Context<Input, Output, Proc>
[INFO] [stdout]    |            ^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: associated items `new` and `run` are never used
[INFO] [stdout]   --> src/processor.rs:56:12
[INFO] [stdout]    |
[INFO] [stdout] 49 | impl<Input, Output, Proc> Context<Input, Output, Proc> 
[INFO] [stdout]    | ------------------------------------------------------ associated items in this implementation
[INFO] [stdout] ...
[INFO] [stdout] 56 |     pub fn new(recv: mpsc::Receiver<Input>,
[INFO] [stdout]    |            ^^^
[INFO] [stdout] ...
[INFO] [stdout] 69 |     pub fn run(mut self) {        
[INFO] [stdout]    |            ^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: function `start_shutdown_manager` is never used
[INFO] [stdout]  --> src/shutdown_manager.rs:5:8
[INFO] [stdout]   |
[INFO] [stdout] 5 | pub fn start_shutdown_manager(shutdown_recv: oneshot::Receiver<()>, list_shutdown: Vec<oneshot::Sender<()>>) {
[INFO] [stdout]   |        ^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: constant `PRODUCER_FILLBUFFER_TIMEOUT_REALTIME` is never used
[INFO] [stdout]   --> src/topology.rs:14:11
[INFO] [stdout]    |
[INFO] [stdout] 14 | pub const PRODUCER_FILLBUFFER_TIMEOUT_REALTIME: Duration = Duration::from_millis(2);
[INFO] [stdout]    |           ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: constant `PRODUCER_FILLBUFFER_TIMEOUT_BATCH` is never used
[INFO] [stdout]   --> src/topology.rs:15:11
[INFO] [stdout]    |
[INFO] [stdout] 15 | pub const PRODUCER_FILLBUFFER_TIMEOUT_BATCH: Duration = Duration::from_millis(50);
[INFO] [stdout]    |           ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: constant `BATCH_SIZE` is never used
[INFO] [stdout]   --> src/topology.rs:17:11
[INFO] [stdout]    |
[INFO] [stdout] 17 | pub const BATCH_SIZE: usize = 100;
[INFO] [stdout]    |           ^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: constant `BATCH_TIMEOUT` is never used
[INFO] [stdout]   --> src/topology.rs:18:11
[INFO] [stdout]    |
[INFO] [stdout] 18 | pub const BATCH_TIMEOUT: Duration = Duration::from_millis(50);
[INFO] [stdout]    |           ^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: constant `CONCURRENCY` is never used
[INFO] [stdout]   --> src/topology.rs:19:11
[INFO] [stdout]    |
[INFO] [stdout] 19 | pub const CONCURRENCY: i32 = 1;
[INFO] [stdout]    |           ^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: constant `BUFFER_SIZE` is never used
[INFO] [stdout]   --> src/topology.rs:20:11
[INFO] [stdout]    |
[INFO] [stdout] 20 | pub const BUFFER_SIZE: usize = 10;
[INFO] [stdout]    |           ^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: constant `BUFFER_POOL_SIZE` is never used
[INFO] [stdout]   --> src/topology.rs:21:11
[INFO] [stdout]    |
[INFO] [stdout] 21 | pub const BUFFER_POOL_SIZE: usize = 100;
[INFO] [stdout]    |           ^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: enum `ProcessingType` is never used
[INFO] [stdout]   --> src/topology.rs:39:10
[INFO] [stdout]    |
[INFO] [stdout] 39 | pub enum ProcessingType {
[INFO] [stdout]    |          ^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: function `start_producer` is never used
[INFO] [stdout]   --> src/topology.rs:48:4
[INFO] [stdout]    |
[INFO] [stdout] 48 | fn start_producer<T, Prod, F> (producer_factory: F,
[INFO] [stdout]    |    ^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: struct `Config` is never constructed
[INFO] [stdout]   --> src/topology.rs:98:12
[INFO] [stdout]    |
[INFO] [stdout] 98 | pub struct Config<Output> {
[INFO] [stdout]    |            ^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: function `start_processor` is never used
[INFO] [stdout]    --> src/topology.rs:104:4
[INFO] [stdout]     |
[INFO] [stdout] 104 | fn start_processor<Input, Output, Proc, F> (processor_factory: F,
[INFO] [stdout]     |    ^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: function `start_batch_processor` is never used
[INFO] [stdout]    --> src/topology.rs:152:4
[INFO] [stdout]     |
[INFO] [stdout] 152 | fn start_batch_processor<Input, Proc, F> (batcher_factory: F,
[INFO] [stdout]     |    ^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: function `run_topology_1` is never used
[INFO] [stdout]    --> src/topology.rs:215:8
[INFO] [stdout]     |
[INFO] [stdout] 215 | pub fn run_topology_1<Prod, ProdFactory, Input, Output, Proc, ProcFactory>
[INFO] [stdout]     |        ^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: function `run_topology_2` is never used
[INFO] [stdout]    --> src/topology.rs:261:8
[INFO] [stdout]     |
[INFO] [stdout] 261 | pub fn run_topology_2<Prod, ProdFactory, 
[INFO] [stdout]     |        ^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: function `run_topology_3` is never used
[INFO] [stdout]    --> src/topology.rs:332:8
[INFO] [stdout]     |
[INFO] [stdout] 332 | pub fn run_topology_3<Prod, ProdFactory, Layer1Input, 
[INFO] [stdout]     |        ^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: function `run_topology_4` is never used
[INFO] [stdout]    --> src/topology.rs:421:8
[INFO] [stdout]     |
[INFO] [stdout] 421 | pub fn run_topology_4<Prod, ProdFactory, Layer1Input, 
[INFO] [stdout]     |        ^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: function `run_topology_5` is never used
[INFO] [stdout]    --> src/topology.rs:530:8
[INFO] [stdout]     |
[INFO] [stdout] 530 | pub fn run_topology_5<Prod, ProdFactory, Layer1Input, 
[INFO] [stdout]     |        ^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: function `run_topology_1_with_batcher` is never used
[INFO] [stdout]    --> src/topology.rs:663:8
[INFO] [stdout]     |
[INFO] [stdout] 663 | pub fn run_topology_1_with_batcher<Prod, ProdFactory, Input, 
[INFO] [stdout]     |        ^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: function `run_topology_2_with_batcher` is never used
[INFO] [stdout]    --> src/topology.rs:735:8
[INFO] [stdout]     |
[INFO] [stdout] 735 | pub fn run_topology_2_with_batcher<Prod, ProdFactory, 
[INFO] [stdout]     |        ^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: function `run_topology_3_with_batcher` is never used
[INFO] [stdout]    --> src/topology.rs:825:8
[INFO] [stdout]     |
[INFO] [stdout] 825 | pub fn run_topology_3_with_batcher<Prod, ProdFactory, Layer1Input, 
[INFO] [stdout]     |        ^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: function `run_topology_4_with_batcher` is never used
[INFO] [stdout]    --> src/topology.rs:934:8
[INFO] [stdout]     |
[INFO] [stdout] 934 | pub fn run_topology_4_with_batcher<Prod, ProdFactory, Layer1Input, 
[INFO] [stdout]     |        ^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: function `run_topology_5_with_batcher` is never used
[INFO] [stdout]     --> src/topology.rs:1062:8
[INFO] [stdout]      |
[INFO] [stdout] 1062 | pub fn run_topology_5_with_batcher<Prod, ProdFactory, Layer1Input, 
[INFO] [stdout]      |        ^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: type alias `StageName` is never used
[INFO] [stdout]  --> src/dispatcher.rs:9:10
[INFO] [stdout]   |
[INFO] [stdout] 9 | pub type StageName = String;
[INFO] [stdout]   |          ^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: enum `InternalDispatchError` is never used
[INFO] [stdout]   --> src/dispatcher.rs:22:6
[INFO] [stdout]    |
[INFO] [stdout] 22 | enum InternalDispatchError<T> {
[INFO] [stdout]    |      ^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: enum `DispatchError` is never used
[INFO] [stdout]   --> src/dispatcher.rs:34:10
[INFO] [stdout]    |
[INFO] [stdout] 34 | pub enum DispatchError<T> {
[INFO] [stdout]    |          ^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: variant `SendersRepetive` is never constructed
[INFO] [stdout]   --> src/dispatcher.rs:52:5
[INFO] [stdout]    |
[INFO] [stdout] 51 | pub enum StatusResult {
[INFO] [stdout]    |          ------------ variant in this enum
[INFO] [stdout] 52 |     SendersRepetive
[INFO] [stdout]    |     ^^^^^^^^^^^^^^^
[INFO] [stdout]    |
[INFO] [stdout]    = note: `StatusResult` has a derived impl for the trait `Debug`, but this is intentionally ignored during dead code analysis
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: struct `Dispatcher` is never constructed
[INFO] [stdout]   --> src/dispatcher.rs:56:12
[INFO] [stdout]    |
[INFO] [stdout] 56 | pub struct Dispatcher<T> {
[INFO] [stdout]    |            ^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: multiple associated items are never used
[INFO] [stdout]    --> src/dispatcher.rs:69:12
[INFO] [stdout]     |
[INFO] [stdout] 63  | impl<T> Dispatcher<T> 
[INFO] [stdout]     | --------------------- associated items in this implementation
[INFO] [stdout] ...
[INFO] [stdout] 69  |     pub fn new(channels: IndexMap<StageName, mpsc::Sender<T>>, 
[INFO] [stdout]     |            ^^^
[INFO] [stdout] ...
[INFO] [stdout] 104 |     pub async fn dispatch(&mut self, msg: T, batch_key: Option<String>) -> Result<(), DispatchError<T>> {
[INFO] [stdout]     |                  ^^^^^^^^
[INFO] [stdout] ...
[INFO] [stdout] 179 |     async fn partition(&mut self, msg: T, batch_key: String) -> Result<(), DispatchError<T>> {
[INFO] [stdout]     |              ^^^^^^^^^
[INFO] [stdout] ...
[INFO] [stdout] 218 |     async fn broadcast(&mut self, msg: T) -> Result<(), DispatchError<T>> {
[INFO] [stdout]     |              ^^^^^^^^^
[INFO] [stdout] ...
[INFO] [stdout] 270 |     async fn roundrobin(&mut self, mut msg: T) -> Result<(), DispatchError<T>> {
[INFO] [stdout]     |              ^^^^^^^^^^
[INFO] [stdout] ...
[INFO] [stdout] 319 |     async fn logic_roundrobin(&mut self, mut msg: T) -> Result<(), InternalDispatchError<T>> {
[INFO] [stdout]     |              ^^^^^^^^^^^^^^^^
[INFO] [stdout] ...
[INFO] [stdout] 368 |     fn next_index(&mut self) -> usize {
[INFO] [stdout]     |        ^^^^^^^^^^
[INFO] [stdout] ...
[INFO] [stdout] 383 |     fn list_check(channels: &IndexMap<StageName, mpsc::Sender<T>>) -> Result<(), ()> {
[INFO] [stdout]     |        ^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: struct `Context` is never constructed
[INFO] [stdout]   --> src/producer.rs:42:12
[INFO] [stdout]    |
[INFO] [stdout] 42 | pub struct Context<T, Prod> 
[INFO] [stdout]    |            ^^^^^^^
[INFO] [stdout]    |
[INFO] [stdout]    = note: `#[warn(dead_code)]` on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: associated items `new` and `run` are never used
[INFO] [stdout]   --> src/producer.rs:57:12
[INFO] [stdout]    |
[INFO] [stdout] 51 | impl<T, Prod> Context<T, Prod> 
[INFO] [stdout]    | ------------------------------ associated items in this implementation
[INFO] [stdout] ...
[INFO] [stdout] 57 |     pub fn new(dispatcher: Dispatcher<T>,
[INFO] [stdout]    |            ^^^
[INFO] [stdout] ...
[INFO] [stdout] 78 |     pub fn run(mut self) {
[INFO] [stdout]    |            ^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: struct `Context` is never constructed
[INFO] [stdout]   --> src/batcher.rs:29:12
[INFO] [stdout]    |
[INFO] [stdout] 29 | pub struct Context<Input, Proc>
[INFO] [stdout]    |            ^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: associated items `new` and `run` are never used
[INFO] [stdout]   --> src/batcher.rs:48:12
[INFO] [stdout]    |
[INFO] [stdout] 42 | impl<Input, Proc> Context<Input, Proc> 
[INFO] [stdout]    | -------------------------------------- associated items in this implementation
[INFO] [stdout] ...
[INFO] [stdout] 48 |     pub fn new(recv: mpsc::Receiver<Input>,
[INFO] [stdout]    |            ^^^
[INFO] [stdout] ...
[INFO] [stdout] 64 |     pub fn run(mut self) {        
[INFO] [stdout]    |            ^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: struct `Context` is never constructed
[INFO] [stdout]   --> src/processor.rs:39:12
[INFO] [stdout]    |
[INFO] [stdout] 39 | pub struct Context<Input, Output, Proc>
[INFO] [stdout]    |            ^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: associated items `new` and `run` are never used
[INFO] [stdout]   --> src/processor.rs:56:12
[INFO] [stdout]    |
[INFO] [stdout] 49 | impl<Input, Output, Proc> Context<Input, Output, Proc> 
[INFO] [stdout]    | ------------------------------------------------------ associated items in this implementation
[INFO] [stdout] ...
[INFO] [stdout] 56 |     pub fn new(recv: mpsc::Receiver<Input>,
[INFO] [stdout]    |            ^^^
[INFO] [stdout] ...
[INFO] [stdout] 69 |     pub fn run(mut self) {        
[INFO] [stdout]    |            ^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: function `start_shutdown_manager` is never used
[INFO] [stdout]  --> src/shutdown_manager.rs:5:8
[INFO] [stdout]   |
[INFO] [stdout] 5 | pub fn start_shutdown_manager(shutdown_recv: oneshot::Receiver<()>, list_shutdown: Vec<oneshot::Sender<()>>) {
[INFO] [stdout]   |        ^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: constant `PRODUCER_FILLBUFFER_TIMEOUT_REALTIME` is never used
[INFO] [stdout]   --> src/topology.rs:14:11
[INFO] [stdout]    |
[INFO] [stdout] 14 | pub const PRODUCER_FILLBUFFER_TIMEOUT_REALTIME: Duration = Duration::from_millis(2);
[INFO] [stdout]    |           ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: constant `PRODUCER_FILLBUFFER_TIMEOUT_BATCH` is never used
[INFO] [stdout]   --> src/topology.rs:15:11
[INFO] [stdout]    |
[INFO] [stdout] 15 | pub const PRODUCER_FILLBUFFER_TIMEOUT_BATCH: Duration = Duration::from_millis(50);
[INFO] [stdout]    |           ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: constant `BATCH_SIZE` is never used
[INFO] [stdout]   --> src/topology.rs:17:11
[INFO] [stdout]    |
[INFO] [stdout] 17 | pub const BATCH_SIZE: usize = 100;
[INFO] [stdout]    |           ^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: constant `BATCH_TIMEOUT` is never used
[INFO] [stdout]   --> src/topology.rs:18:11
[INFO] [stdout]    |
[INFO] [stdout] 18 | pub const BATCH_TIMEOUT: Duration = Duration::from_millis(50);
[INFO] [stdout]    |           ^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: constant `CONCURRENCY` is never used
[INFO] [stdout]   --> src/topology.rs:19:11
[INFO] [stdout]    |
[INFO] [stdout] 19 | pub const CONCURRENCY: i32 = 1;
[INFO] [stdout]    |           ^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: constant `BUFFER_SIZE` is never used
[INFO] [stdout]   --> src/topology.rs:20:11
[INFO] [stdout]    |
[INFO] [stdout] 20 | pub const BUFFER_SIZE: usize = 10;
[INFO] [stdout]    |           ^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: constant `BUFFER_POOL_SIZE` is never used
[INFO] [stdout]   --> src/topology.rs:21:11
[INFO] [stdout]    |
[INFO] [stdout] 21 | pub const BUFFER_POOL_SIZE: usize = 100;
[INFO] [stdout]    |           ^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: enum `ProcessingType` is never used
[INFO] [stdout]   --> src/topology.rs:39:10
[INFO] [stdout]    |
[INFO] [stdout] 39 | pub enum ProcessingType {
[INFO] [stdout]    |          ^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: function `start_producer` is never used
[INFO] [stdout]   --> src/topology.rs:48:4
[INFO] [stdout]    |
[INFO] [stdout] 48 | fn start_producer<T, Prod, F> (producer_factory: F,
[INFO] [stdout]    |    ^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: struct `Config` is never constructed
[INFO] [stdout]   --> src/topology.rs:98:12
[INFO] [stdout]    |
[INFO] [stdout] 98 | pub struct Config<Output> {
[INFO] [stdout]    |            ^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: function `start_processor` is never used
[INFO] [stdout]    --> src/topology.rs:104:4
[INFO] [stdout]     |
[INFO] [stdout] 104 | fn start_processor<Input, Output, Proc, F> (processor_factory: F,
[INFO] [stdout]     |    ^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: function `start_batch_processor` is never used
[INFO] [stdout]    --> src/topology.rs:152:4
[INFO] [stdout]     |
[INFO] [stdout] 152 | fn start_batch_processor<Input, Proc, F> (batcher_factory: F,
[INFO] [stdout]     |    ^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: function `run_topology_1` is never used
[INFO] [stdout]    --> src/topology.rs:215:8
[INFO] [stdout]     |
[INFO] [stdout] 215 | pub fn run_topology_1<Prod, ProdFactory, Input, Output, Proc, ProcFactory>
[INFO] [stdout]     |        ^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: function `run_topology_2` is never used
[INFO] [stdout]    --> src/topology.rs:261:8
[INFO] [stdout]     |
[INFO] [stdout] 261 | pub fn run_topology_2<Prod, ProdFactory, 
[INFO] [stdout]     |        ^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: function `run_topology_3` is never used
[INFO] [stdout]    --> src/topology.rs:332:8
[INFO] [stdout]     |
[INFO] [stdout] 332 | pub fn run_topology_3<Prod, ProdFactory, Layer1Input, 
[INFO] [stdout]     |        ^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: function `run_topology_4` is never used
[INFO] [stdout]    --> src/topology.rs:421:8
[INFO] [stdout]     |
[INFO] [stdout] 421 | pub fn run_topology_4<Prod, ProdFactory, Layer1Input, 
[INFO] [stdout]     |        ^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: function `run_topology_5` is never used
[INFO] [stdout]    --> src/topology.rs:530:8
[INFO] [stdout]     |
[INFO] [stdout] 530 | pub fn run_topology_5<Prod, ProdFactory, Layer1Input, 
[INFO] [stdout]     |        ^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: function `run_topology_1_with_batcher` is never used
[INFO] [stdout]    --> src/topology.rs:663:8
[INFO] [stdout]     |
[INFO] [stdout] 663 | pub fn run_topology_1_with_batcher<Prod, ProdFactory, Input, 
[INFO] [stdout]     |        ^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: function `run_topology_2_with_batcher` is never used
[INFO] [stdout]    --> src/topology.rs:735:8
[INFO] [stdout]     |
[INFO] [stdout] 735 | pub fn run_topology_2_with_batcher<Prod, ProdFactory, 
[INFO] [stdout]     |        ^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: function `run_topology_3_with_batcher` is never used
[INFO] [stdout]    --> src/topology.rs:825:8
[INFO] [stdout]     |
[INFO] [stdout] 825 | pub fn run_topology_3_with_batcher<Prod, ProdFactory, Layer1Input, 
[INFO] [stdout]     |        ^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: function `run_topology_4_with_batcher` is never used
[INFO] [stdout]    --> src/topology.rs:934:8
[INFO] [stdout]     |
[INFO] [stdout] 934 | pub fn run_topology_4_with_batcher<Prod, ProdFactory, Layer1Input, 
[INFO] [stdout]     |        ^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: function `run_topology_5_with_batcher` is never used
[INFO] [stdout]     --> src/topology.rs:1062:8
[INFO] [stdout]      |
[INFO] [stdout] 1062 | pub fn run_topology_5_with_batcher<Prod, ProdFactory, Layer1Input, 
[INFO] [stdout]      |        ^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: type alias `StageName` is never used
[INFO] [stdout]  --> src/dispatcher.rs:9:10
[INFO] [stdout]   |
[INFO] [stdout] 9 | pub type StageName = String;
[INFO] [stdout]   |          ^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: enum `InternalDispatchError` is never used
[INFO] [stdout]   --> src/dispatcher.rs:22:6
[INFO] [stdout]    |
[INFO] [stdout] 22 | enum InternalDispatchError<T> {
[INFO] [stdout]    |      ^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: enum `DispatchError` is never used
[INFO] [stdout]   --> src/dispatcher.rs:34:10
[INFO] [stdout]    |
[INFO] [stdout] 34 | pub enum DispatchError<T> {
[INFO] [stdout]    |          ^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: variant `SendersRepetive` is never constructed
[INFO] [stdout]   --> src/dispatcher.rs:52:5
[INFO] [stdout]    |
[INFO] [stdout] 51 | pub enum StatusResult {
[INFO] [stdout]    |          ------------ variant in this enum
[INFO] [stdout] 52 |     SendersRepetive
[INFO] [stdout]    |     ^^^^^^^^^^^^^^^
[INFO] [stdout]    |
[INFO] [stdout]    = note: `StatusResult` has a derived impl for the trait `Debug`, but this is intentionally ignored during dead code analysis
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: struct `Dispatcher` is never constructed
[INFO] [stdout]   --> src/dispatcher.rs:56:12
[INFO] [stdout]    |
[INFO] [stdout] 56 | pub struct Dispatcher<T> {
[INFO] [stdout]    |            ^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: multiple associated items are never used
[INFO] [stdout]    --> src/dispatcher.rs:69:12
[INFO] [stdout]     |
[INFO] [stdout] 63  | impl<T> Dispatcher<T> 
[INFO] [stdout]     | --------------------- associated items in this implementation
[INFO] [stdout] ...
[INFO] [stdout] 69  |     pub fn new(channels: IndexMap<StageName, mpsc::Sender<T>>, 
[INFO] [stdout]     |            ^^^
[INFO] [stdout] ...
[INFO] [stdout] 104 |     pub async fn dispatch(&mut self, msg: T, batch_key: Option<String>) -> Result<(), DispatchError<T>> {
[INFO] [stdout]     |                  ^^^^^^^^
[INFO] [stdout] ...
[INFO] [stdout] 179 |     async fn partition(&mut self, msg: T, batch_key: String) -> Result<(), DispatchError<T>> {
[INFO] [stdout]     |              ^^^^^^^^^
[INFO] [stdout] ...
[INFO] [stdout] 218 |     async fn broadcast(&mut self, msg: T) -> Result<(), DispatchError<T>> {
[INFO] [stdout]     |              ^^^^^^^^^
[INFO] [stdout] ...
[INFO] [stdout] 270 |     async fn roundrobin(&mut self, mut msg: T) -> Result<(), DispatchError<T>> {
[INFO] [stdout]     |              ^^^^^^^^^^
[INFO] [stdout] ...
[INFO] [stdout] 319 |     async fn logic_roundrobin(&mut self, mut msg: T) -> Result<(), InternalDispatchError<T>> {
[INFO] [stdout]     |              ^^^^^^^^^^^^^^^^
[INFO] [stdout] ...
[INFO] [stdout] 368 |     fn next_index(&mut self) -> usize {
[INFO] [stdout]     |        ^^^^^^^^^^
[INFO] [stdout] ...
[INFO] [stdout] 383 |     fn list_check(channels: &IndexMap<StageName, mpsc::Sender<T>>) -> Result<(), ()> {
[INFO] [stdout]     |        ^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: 35 warnings emitted
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: 35 warnings emitted
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error: invalid character `'('` in crate name: `complex(2 layer)`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error: invalid character `' '` in crate name: `complex(2 layer)`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error: invalid character `')'` in crate name: `complex(2 layer)`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0432]: unresolved import `tokio_sky::builtin::pulsar_processor`
[INFO] [stdout]  --> examples/pulsar_batcher.rs:2:25
[INFO] [stdout]   |
[INFO] [stdout] 2 | use tokio_sky::builtin::pulsar_processor::PulsarProcessor;
[INFO] [stdout]   |                         ^^^^^^^^^^^^^^^^ could not find `pulsar_processor` in `builtin`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0432]: unresolved import `tokio_sky::builtin::pulsar_processor`
[INFO] [stdout]  --> examples/pulsar_processor.rs:1:25
[INFO] [stdout]   |
[INFO] [stdout] 1 | use tokio_sky::builtin::pulsar_processor::PulsarProcessor;
[INFO] [stdout]   |                         ^^^^^^^^^^^^^^^^ could not find `pulsar_processor` in `builtin`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0432]: unresolved import `pulsar`
[INFO] [stdout]  --> examples/pulsar_batcher.rs:1:5
[INFO] [stdout]   |
[INFO] [stdout] 1 | use pulsar::ProducerOptions;
[INFO] [stdout]   |     ^^^^^^ use of undeclared crate or module `pulsar`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error: aborting due to 3 previous errors
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error: cannot find derive macro `Serialize` in this scope
[INFO] [stdout]   --> examples/pulsar_batcher.rs:79:10
[INFO] [stdout]    |
[INFO] [stdout] 79 | #[derive(Serialize, Deserialize)]
[INFO] [stdout]    |          ^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error: cannot find derive macro `Serialize` in this scope
[INFO] [stdout]   --> examples/pulsar_processor.rs:70:10
[INFO] [stdout]    |
[INFO] [stdout] 70 | #[derive(Serialize, Deserialize)]
[INFO] [stdout]    |          ^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stderr] error: could not compile `tokio_sky` (example "complex(2 layer)") due to 4 previous errors
[INFO] [stderr] warning: build failed, waiting for other jobs to finish...
[INFO] [stdout] error: cannot find derive macro `Deserialize` in this scope
[INFO] [stdout]   --> examples/pulsar_batcher.rs:79:21
[INFO] [stdout]    |
[INFO] [stdout] 79 | #[derive(Serialize, Deserialize)]
[INFO] [stdout]    |                     ^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0432]: unresolved import `blueriver`
[INFO] [stdout]  --> examples/ordering_and_paritioning.rs:1:5
[INFO] [stdout]   |
[INFO] [stdout] 1 | use blueriver::run_topology_1_with_batcher;
[INFO] [stdout]   |     ^^^^^^^^^ use of undeclared crate or module `blueriver`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error: cannot find attribute `async_trait` in this scope
[INFO] [stdout]   --> examples/pulsar_batcher.rs:97:3
[INFO] [stdout]    |
[INFO] [stdout] 97 | #[async_trait]
[INFO] [stdout]    |   ^^^^^^^^^^^
[INFO] [stdout]    |
[INFO] [stdout]    = help: consider importing one of these items:
[INFO] [stdout]            async_trait::async_trait
[INFO] [stdout]            tokio_sky::async_trait
[INFO] [stdout]    = note: `async_trait` is in scope, but it is a crate, not an attribute
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error: associated function in `impl` without body
[INFO] [stdout]    --> examples/dynamic_batching.rs:146:5
[INFO] [stdout]     |
[INFO] [stdout] 146 |     async fn drain(&mut self, batch: Vec<Product>);
[INFO] [stdout]     |     ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^-
[INFO] [stdout]     |                                                   |
[INFO] [stdout]     |                                                   help: provide a definition for the function: `{ <body> }`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error: cannot find attribute `async_trait` in this scope
[INFO] [stdout]    --> examples/pulsar_batcher.rs:123:3
[INFO] [stdout]     |
[INFO] [stdout] 123 | #[async_trait]
[INFO] [stdout]     |   ^^^^^^^^^^^
[INFO] [stdout]     |
[INFO] [stdout]     = help: consider importing one of these items:
[INFO] [stdout]             async_trait::async_trait
[INFO] [stdout]             tokio_sky::async_trait
[INFO] [stdout]     = note: `async_trait` is in scope, but it is a crate, not an attribute
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error: cannot find derive macro `Deserialize` in this scope
[INFO] [stdout]   --> examples/pulsar_processor.rs:70:21
[INFO] [stdout]    |
[INFO] [stdout] 70 | #[derive(Serialize, Deserialize)]
[INFO] [stdout]    |                     ^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error: invalid character `'('` in crate name: `complex(3 layer)`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error: invalid character `' '` in crate name: `complex(3 layer)`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error: invalid character `')'` in crate name: `complex(3 layer)`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error: aborting due to 3 previous errors
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error: cannot find attribute `async_trait` in this scope
[INFO] [stdout]   --> examples/pulsar_processor.rs:88:3
[INFO] [stdout]    |
[INFO] [stdout] 88 | #[async_trait]
[INFO] [stdout]    |   ^^^^^^^^^^^
[INFO] [stdout]    |
[INFO] [stdout]    = help: consider importing one of these items:
[INFO] [stdout]            async_trait::async_trait
[INFO] [stdout]            tokio_sky::async_trait
[INFO] [stdout]    = note: `async_trait` is in scope, but it is a crate, not an attribute
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: failed to resolve: use of undeclared crate or module `blueriver`
[INFO] [stdout]  --> examples/dynamic_batching.rs:2:5
[INFO] [stdout]   |
[INFO] [stdout] 2 | use blueriver::{run_topology_1_with_batcher, batcher::BatchProcessor, BATCH_TIMEOUT};
[INFO] [stdout]   |     ^^^^^^^^^ use of undeclared crate or module `blueriver`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0432]: unresolved import `blueriver`
[INFO] [stdout]  --> examples/dynamic_batching.rs:2:5
[INFO] [stdout]   |
[INFO] [stdout] 2 | use blueriver::{run_topology_1_with_batcher, batcher::BatchProcessor, BATCH_TIMEOUT};
[INFO] [stdout]   |     ^^^^^^^^^ use of undeclared crate or module `blueriver`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error: cannot find attribute `async_trait` in this scope
[INFO] [stdout]   --> examples/collector.rs:71:3
[INFO] [stdout]    |
[INFO] [stdout] 71 | #[async_trait]
[INFO] [stdout]    |   ^^^^^^^^^^^
[INFO] [stdout]    |
[INFO] [stdout]    = help: consider importing one of these items:
[INFO] [stdout]            async_trait::async_trait
[INFO] [stdout]            tokio_sky::async_trait
[INFO] [stdout]    = note: `async_trait` is in scope, but it is a crate, not an attribute
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: failed to resolve: use of undeclared crate or module `proto`
[INFO] [stdout]   --> examples/pulsar_batcher.rs:29:21
[INFO] [stdout]    |
[INFO] [stdout] 29 |             r#type: proto::schema::Type::String as i32,
[INFO] [stdout]    |                     ^^^^^ use of undeclared crate or module `proto`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0425]: cannot find function `channel` in this scope
[INFO] [stdout]  --> examples/collector.rs:5:45
[INFO] [stdout]   |
[INFO] [stdout] 5 |     let (colletor_sender, collector_recv) = channel::<i32>(500);
[INFO] [stdout]   |                                             ^^^^^^^ not found in this scope
[INFO] [stdout]   |
[INFO] [stdout] help: consider importing one of these items
[INFO] [stdout]   |
[INFO] [stdout] 2 + use std::sync::mpsc::channel;
[INFO] [stdout]   |
[INFO] [stdout] 2 + use tokio::sync::broadcast::channel;
[INFO] [stdout]   |
[INFO] [stdout] 2 + use tokio::sync::mpsc::channel;
[INFO] [stdout]   |
[INFO] [stdout] 2 + use tokio::sync::oneshot::channel;
[INFO] [stdout]   |
[INFO] [stdout]     and 1 other candidate
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: failed to resolve: use of undeclared type `Duration`
[INFO] [stdout]  --> examples/collector.rs:9:19
[INFO] [stdout]   |
[INFO] [stdout] 9 |     let timeout = Duration::from_secs(1);
[INFO] [stdout]   |                   ^^^^^^^^ use of undeclared type `Duration`
[INFO] [stdout]   |
[INFO] [stdout] help: consider importing one of these items
[INFO] [stdout]   |
[INFO] [stdout] 2 + use core::time::Duration;
[INFO] [stdout]   |
[INFO] [stdout] 2 + use std::time::Duration;
[INFO] [stdout]   |
[INFO] [stdout] 2 + use tokio::time::Duration;
[INFO] [stdout]   |
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: failed to resolve: use of undeclared type `RouterType`
[INFO] [stdout]   --> examples/collector.rs:13:27
[INFO] [stdout]    |
[INFO] [stdout] 13 |     let producer_router = RouterType::RoundRobin;
[INFO] [stdout]    |                           ^^^^^^^^^^ use of undeclared type `RouterType`
[INFO] [stdout]    |
[INFO] [stdout] help: consider importing this enum
[INFO] [stdout]    |
[INFO] [stdout] 2  + use tokio_sky::RouterType;
[INFO] [stdout]    |
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0405]: cannot find trait `Processor` in this scope
[INFO] [stdout]   --> examples/collector.rs:72:6
[INFO] [stdout]    |
[INFO] [stdout] 72 | impl Processor<i32, ()> for Layer1Process {
[INFO] [stdout]    |      ^^^^^^^^^ not found in this scope
[INFO] [stdout]    |
[INFO] [stdout] help: consider importing this trait
[INFO] [stdout]    |
[INFO] [stdout] 2  + use tokio_sky::Processor;
[INFO] [stdout]    |
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0412]: cannot find type `ProcResult` in this scope
[INFO] [stdout]   --> examples/collector.rs:76:54
[INFO] [stdout]    |
[INFO] [stdout] 76 |     async fn handle_message(&mut self, msg: i32) ->  ProcResult<()> {
[INFO] [stdout]    |                                                      ^^^^^^^^^^ not found in this scope
[INFO] [stdout]    |
[INFO] [stdout] help: consider importing this enum
[INFO] [stdout]    |
[INFO] [stdout] 2  + use tokio_sky::ProcResult;
[INFO] [stdout]    |
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: failed to resolve: use of undeclared type `ProcResult`
[INFO] [stdout]   --> examples/collector.rs:82:9
[INFO] [stdout]    |
[INFO] [stdout] 82 |         ProcResult::Continue
[INFO] [stdout]    |         ^^^^^^^^^^ use of undeclared type `ProcResult`
[INFO] [stdout]    |
[INFO] [stdout] help: consider importing this enum
[INFO] [stdout]    |
[INFO] [stdout] 2  + use tokio_sky::ProcResult;
[INFO] [stdout]    |
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stderr] error: could not compile `tokio_sky` (example "complex(3 layer)") due to 4 previous errors
[INFO] [stdout] error[E0433]: failed to resolve: use of undeclared crate or module `proto`
[INFO] [stdout]   --> examples/pulsar_processor.rs:21:21
[INFO] [stdout]    |
[INFO] [stdout] 21 |             r#type: proto::schema::Type::String as i32,
[INFO] [stdout]    |                     ^^^^^ use of undeclared crate or module `proto`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0706]: functions in traits cannot be declared `async`
[INFO] [stdout]   --> examples/collector.rs:73:5
[INFO] [stdout]    |
[INFO] [stdout] 73 |     async fn init(&mut self) {}
[INFO] [stdout]    |     -----^^^^^^^^^^^^^^^^^^^
[INFO] [stdout]    |     |
[INFO] [stdout]    |     `async` because of this
[INFO] [stdout]    |
[INFO] [stdout]    = note: `async` trait functions are not currently supported
[INFO] [stdout]    = note: consider using the `async-trait` crate: https://crates.io/crates/async-trait
[INFO] [stdout]    = note: see issue #91611 <https://github.com/rust-lang/rust/issues/91611> for more information
[INFO] [stdout]    = help: add `#![feature(async_fn_in_trait)]` to the crate attributes to enable
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0706]: functions in traits cannot be declared `async`
[INFO] [stdout]   --> examples/collector.rs:74:5
[INFO] [stdout]    |
[INFO] [stdout] 74 |     async fn terminate(&mut self) {}
[INFO] [stdout]    |     -----^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout]    |     |
[INFO] [stdout]    |     `async` because of this
[INFO] [stdout]    |
[INFO] [stdout]    = note: `async` trait functions are not currently supported
[INFO] [stdout]    = note: consider using the `async-trait` crate: https://crates.io/crates/async-trait
[INFO] [stdout]    = note: see issue #91611 <https://github.com/rust-lang/rust/issues/91611> for more information
[INFO] [stdout]    = help: add `#![feature(async_fn_in_trait)]` to the crate attributes to enable
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0706]: functions in traits cannot be declared `async`
[INFO] [stdout]   --> examples/collector.rs:76:5
[INFO] [stdout]    |
[INFO] [stdout] 76 |     async fn handle_message(&mut self, msg: i32) ->  ProcResult<()> {
[INFO] [stdout]    |     -----^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout]    |     |
[INFO] [stdout]    |     `async` because of this
[INFO] [stdout]    |
[INFO] [stdout]    = note: `async` trait functions are not currently supported
[INFO] [stdout]    = note: consider using the `async-trait` crate: https://crates.io/crates/async-trait
[INFO] [stdout]    = note: see issue #91611 <https://github.com/rust-lang/rust/issues/91611> for more information
[INFO] [stdout]    = help: add `#![feature(async_fn_in_trait)]` to the crate attributes to enable
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error: cannot find attribute `async_trait` in this scope
[INFO] [stdout]   --> examples/batch_insert_mysql.rs:73:3
[INFO] [stdout]    |
[INFO] [stdout] 73 | #[async_trait]
[INFO] [stdout]    |   ^^^^^^^^^^^
[INFO] [stdout]    |
[INFO] [stdout]    = help: consider importing one of these items:
[INFO] [stdout]            async_trait::async_trait
[INFO] [stdout]            tokio_sky::async_trait
[INFO] [stdout]    = note: `async_trait` is in scope, but it is a crate, not an attribute
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error: cannot find attribute `async_trait` in this scope
[INFO] [stdout]   --> examples/ordering_and_paritioning.rs:96:3
[INFO] [stdout]    |
[INFO] [stdout] 96 | #[async_trait]
[INFO] [stdout]    |   ^^^^^^^^^^^
[INFO] [stdout]    |
[INFO] [stdout]    = help: consider importing one of these items:
[INFO] [stdout]            async_trait::async_trait
[INFO] [stdout]            tokio_sky::async_trait
[INFO] [stdout]    = note: `async_trait` is in scope, but it is a crate, not an attribute
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error: cannot find attribute `async_trait` in this scope
[INFO] [stdout]    --> examples/ordering_and_paritioning.rs:121:3
[INFO] [stdout]     |
[INFO] [stdout] 121 | #[async_trait]
[INFO] [stdout]     |   ^^^^^^^^^^^
[INFO] [stdout]     |
[INFO] [stdout]     = help: consider importing one of these items:
[INFO] [stdout]             async_trait::async_trait
[INFO] [stdout]             tokio_sky::async_trait
[INFO] [stdout]     = note: `async_trait` is in scope, but it is a crate, not an attribute
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error: cannot find attribute `async_trait` in this scope
[INFO] [stdout]    --> examples/ordering_and_paritioning.rs:148:3
[INFO] [stdout]     |
[INFO] [stdout] 148 | #[async_trait]
[INFO] [stdout]     |   ^^^^^^^^^^^
[INFO] [stdout]     |
[INFO] [stdout]     = help: consider importing one of these items:
[INFO] [stdout]             async_trait::async_trait
[INFO] [stdout]             tokio_sky::async_trait
[INFO] [stdout]     = note: `async_trait` is in scope, but it is a crate, not an attribute
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error: cannot find attribute `async_trait` in this scope
[INFO] [stdout]   --> examples/dynamic_batching.rs:77:3
[INFO] [stdout]    |
[INFO] [stdout] 77 | #[async_trait]
[INFO] [stdout]    |   ^^^^^^^^^^^
[INFO] [stdout]    |
[INFO] [stdout]    = help: consider importing one of these items:
[INFO] [stdout]            async_trait::async_trait
[INFO] [stdout]            tokio_sky::async_trait
[INFO] [stdout]    = note: `async_trait` is in scope, but it is a crate, not an attribute
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error: cannot find attribute `async_trait` in this scope
[INFO] [stdout]    --> examples/batch_insert_mysql.rs:100:3
[INFO] [stdout]     |
[INFO] [stdout] 100 | #[async_trait]
[INFO] [stdout]     |   ^^^^^^^^^^^
[INFO] [stdout]     |
[INFO] [stdout]     = help: consider importing one of these items:
[INFO] [stdout]             async_trait::async_trait
[INFO] [stdout]             tokio_sky::async_trait
[INFO] [stdout]     = note: `async_trait` is in scope, but it is a crate, not an attribute
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error: cannot find attribute `async_trait` in this scope
[INFO] [stdout]    --> examples/dynamic_batching.rs:110:3
[INFO] [stdout]     |
[INFO] [stdout] 110 | #[async_trait]
[INFO] [stdout]     |   ^^^^^^^^^^^
[INFO] [stdout]     |
[INFO] [stdout]     = help: consider importing one of these items:
[INFO] [stdout]             async_trait::async_trait
[INFO] [stdout]             tokio_sky::async_trait
[INFO] [stdout]     = note: `async_trait` is in scope, but it is a crate, not an attribute
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error: cannot find attribute `async_trait` in this scope
[INFO] [stdout]    --> examples/batch_insert_mysql.rs:127:3
[INFO] [stdout]     |
[INFO] [stdout] 127 | #[async_trait]
[INFO] [stdout]     |   ^^^^^^^^^^^
[INFO] [stdout]     |
[INFO] [stdout]     = help: consider importing one of these items:
[INFO] [stdout]             async_trait::async_trait
[INFO] [stdout]             tokio_sky::async_trait
[INFO] [stdout]     = note: `async_trait` is in scope, but it is a crate, not an attribute
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error: cannot find attribute `async_trait` in this scope
[INFO] [stdout]    --> examples/dynamic_batching.rs:141:3
[INFO] [stdout]     |
[INFO] [stdout] 141 | #[async_trait]
[INFO] [stdout]     |   ^^^^^^^^^^^
[INFO] [stdout]     |
[INFO] [stdout]     = help: consider importing one of these items:
[INFO] [stdout]             async_trait::async_trait
[INFO] [stdout]             tokio_sky::async_trait
[INFO] [stdout]     = note: `async_trait` is in scope, but it is a crate, not an attribute
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error: cannot find macro `params` in this scope
[INFO] [stdout]    --> examples/batch_insert_mysql.rs:143:43
[INFO] [stdout]     |
[INFO] [stdout] 143 |             .with(batch.iter().map(|user| params! {
[INFO] [stdout]     |                                           ^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: failed to resolve: use of undeclared crate or module `mysql_async`
[INFO] [stdout]   --> examples/batch_insert_mysql.rs:21:16
[INFO] [stdout]    |
[INFO] [stdout] 21 |     let pool = mysql_async::Pool::new(database_url);
[INFO] [stdout]    |                ^^^^^^^^^^^ use of undeclared crate or module `mysql_async`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: failed to resolve: use of undeclared type `RouterType`
[INFO] [stdout]   --> examples/pulsar_batcher.rs:10:27
[INFO] [stdout]    |
[INFO] [stdout] 10 |     let producer_router = RouterType::RoundRobin;
[INFO] [stdout]    |                           ^^^^^^^^^^ use of undeclared type `RouterType`
[INFO] [stdout]    |
[INFO] [stdout] help: consider importing this enum
[INFO] [stdout]    |
[INFO] [stdout] 1  + use tokio_sky::RouterType;
[INFO] [stdout]    |
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: failed to resolve: use of undeclared type `RouterType`
[INFO] [stdout]   --> examples/pulsar_batcher.rs:16:24
[INFO] [stdout]    |
[INFO] [stdout] 16 |     let proc1_router = RouterType::RoundRobin;
[INFO] [stdout]    |                        ^^^^^^^^^^ use of undeclared type `RouterType`
[INFO] [stdout]    |
[INFO] [stdout] help: consider importing this enum
[INFO] [stdout]    |
[INFO] [stdout] 1  + use tokio_sky::RouterType;
[INFO] [stdout]    |
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0412]: cannot find type `Pulsar` in this scope
[INFO] [stdout]   --> examples/pulsar_batcher.rs:26:17
[INFO] [stdout]    |
[INFO] [stdout] 26 |     let pulsar: Pulsar<_> = Pulsar::builder(addr, TokioExecutor).build().await.unwrap();
[INFO] [stdout]    |                 ^^^^^^ not found in this scope
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0425]: cannot find value `TokioExecutor` in this scope
[INFO] [stdout]   --> examples/pulsar_batcher.rs:26:51
[INFO] [stdout]    |
[INFO] [stdout] 26 |     let pulsar: Pulsar<_> = Pulsar::builder(addr, TokioExecutor).build().await.unwrap();
[INFO] [stdout]    |                                                   ^^^^^^^^^^^^^ not found in this scope
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0412]: cannot find type `BATCH_TIMEOUT` in this scope
[INFO] [stdout]   --> examples/pulsar_batcher.rs:40:32
[INFO] [stdout]    |
[INFO] [stdout] 40 |     let batcher_batch_timeout: BATCH_TIMEOUT;
[INFO] [stdout]    |                                ^^^^^^^^^^^^^ not found in this scope
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0425]: cannot find value `proc_factory` in this scope
[INFO] [stdout]   --> examples/pulsar_batcher.rs:57:20
[INFO] [stdout]    |
[INFO] [stdout] 57 |                    proc_factory,
[INFO] [stdout]    |                    ^^^^^^^^^^^^ help: a local variable with a similar name exists: `proc1_factory`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: failed to resolve: use of undeclared type `RouterType`
[INFO] [stdout]  --> examples/pulsar_processor.rs:9:27
[INFO] [stdout]   |
[INFO] [stdout] 9 |     let producer_router = RouterType::RoundRobin;
[INFO] [stdout]   |                           ^^^^^^^^^^ use of undeclared type `RouterType`
[INFO] [stdout]   |
[INFO] [stdout] help: consider importing this enum
[INFO] [stdout]   |
[INFO] [stdout] 1 + use tokio_sky::RouterType;
[INFO] [stdout]   |
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0425]: cannot find value `proc_concurrency` in this scope
[INFO] [stdout]   --> examples/pulsar_batcher.rs:58:20
[INFO] [stdout]    |
[INFO] [stdout] 58 |                    proc_concurrency,
[INFO] [stdout]    |                    ^^^^^^^^^^^^^^^^ help: a local variable with a similar name exists: `proc1_concurrency`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0412]: cannot find type `Pulsar` in this scope
[INFO] [stdout]   --> examples/pulsar_processor.rs:18:17
[INFO] [stdout]    |
[INFO] [stdout] 18 |     let pulsar: Pulsar<_> = Pulsar::builder(addr, TokioExecutor).build().await.unwrap();
[INFO] [stdout]    |                 ^^^^^^ not found in this scope
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0425]: cannot find value `proc_router` in this scope
[INFO] [stdout]   --> examples/pulsar_batcher.rs:59:20
[INFO] [stdout]    |
[INFO] [stdout] 59 |                    proc_router,
[INFO] [stdout]    |                    ^^^^^^^^^^^ help: a local variable with a similar name exists: `proc1_router`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0425]: cannot find value `TokioExecutor` in this scope
[INFO] [stdout]   --> examples/pulsar_processor.rs:18:51
[INFO] [stdout]    |
[INFO] [stdout] 18 |     let pulsar: Pulsar<_> = Pulsar::builder(addr, TokioExecutor).build().await.unwrap();
[INFO] [stdout]    |                                                   ^^^^^^^^^^^^^ not found in this scope
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0405]: cannot find trait `SerializeMessage` in this scope
[INFO] [stdout]   --> examples/pulsar_processor.rs:75:6
[INFO] [stdout]    |
[INFO] [stdout] 75 | impl SerializeMessage for TestData {
[INFO] [stdout]    |      ^^^^^^^^^^^^^^^^ not found in this scope
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0425]: cannot find value `proc_buffer_size` in this scope
[INFO] [stdout]   --> examples/pulsar_batcher.rs:60:20
[INFO] [stdout]    |
[INFO] [stdout] 60 |                    proc_buffer_size,
[INFO] [stdout]    |                    ^^^^^^^^^^^^^^^^ help: a local variable with a similar name exists: `proc1_buffer_size`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0412]: cannot find type `PulsarError` in this scope
[INFO] [stdout]   --> examples/pulsar_processor.rs:76:68
[INFO] [stdout]    |
[INFO] [stdout] 76 |     fn serialize_message(input: Self) -> Result<producer::Message, PulsarError> {
[INFO] [stdout]    |                                                                    ^^^^^^^^^^^ not found in this scope
[INFO] [stdout]    |
[INFO] [stdout] help: you might be missing a type parameter
[INFO] [stdout]    |
[INFO] [stdout] 75 | impl<PulsarError> SerializeMessage for TestData {
[INFO] [stdout]    |     +++++++++++++
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0405]: cannot find trait `SerializeMessage` in this scope
[INFO] [stdout]   --> examples/pulsar_batcher.rs:84:6
[INFO] [stdout]    |
[INFO] [stdout] 84 | impl SerializeMessage for Cat {
[INFO] [stdout]    |      ^^^^^^^^^^^^^^^^ not found in this scope
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0405]: cannot find trait `Producer` in this scope
[INFO] [stdout]   --> examples/pulsar_processor.rs:89:6
[INFO] [stdout]    |
[INFO] [stdout] 89 | impl Producer<TestData> for Prod {
[INFO] [stdout]    |      ^^^^^^^^ not found in this scope
[INFO] [stdout]    |
[INFO] [stdout] help: consider importing this trait
[INFO] [stdout]    |
[INFO] [stdout] 1  + use tokio_sky::Producer;
[INFO] [stdout]    |
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0412]: cannot find type `PulsarError` in this scope
[INFO] [stdout]   --> examples/pulsar_batcher.rs:85:68
[INFO] [stdout]    |
[INFO] [stdout] 85 |     fn serialize_message(input: Self) -> Result<producer::Message, PulsarError> {
[INFO] [stdout]    |                                                                    ^^^^^^^^^^^ not found in this scope
[INFO] [stdout]    |
[INFO] [stdout] help: you might be missing a type parameter
[INFO] [stdout]    |
[INFO] [stdout] 84 | impl<PulsarError> SerializeMessage for Cat {
[INFO] [stdout]    |     +++++++++++++
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0405]: cannot find trait `Producer` in this scope
[INFO] [stdout]   --> examples/pulsar_batcher.rs:98:6
[INFO] [stdout]    |
[INFO] [stdout] 98 | impl Producer<Cat> for Prod {
[INFO] [stdout]    |      ^^^^^^^^ not found in this scope
[INFO] [stdout]    |
[INFO] [stdout] help: consider importing this trait
[INFO] [stdout]    |
[INFO] [stdout] 1  + use tokio_sky::Producer;
[INFO] [stdout]    |
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0412]: cannot find type `VecDeque` in this scope
[INFO] [stdout]   --> examples/pulsar_processor.rs:95:40
[INFO] [stdout]    |
[INFO] [stdout] 95 |     async fn drain(&mut self, _buffer: VecDeque<TestData>) {}
[INFO] [stdout]    |                                        ^^^^^^^^ not found in this scope
[INFO] [stdout]    |
[INFO] [stdout] help: consider importing this struct
[INFO] [stdout]    |
[INFO] [stdout] 1  + use std::collections::VecDeque;
[INFO] [stdout]    |
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0412]: cannot find type `VecDeque` in this scope
[INFO] [stdout]    --> examples/pulsar_batcher.rs:104:40
[INFO] [stdout]     |
[INFO] [stdout] 104 |     async fn drain(&mut self, _buffer: VecDeque<Cat>) {}
[INFO] [stdout]     |                                        ^^^^^^^^ not found in this scope
[INFO] [stdout]     |
[INFO] [stdout] help: consider importing this struct
[INFO] [stdout]     |
[INFO] [stdout] 1   + use std::collections::VecDeque;
[INFO] [stdout]     |
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0412]: cannot find type `VecDeque` in this scope
[INFO] [stdout]    --> examples/pulsar_batcher.rs:106:67
[INFO] [stdout]     |
[INFO] [stdout] 106 |     async fn fill_buffer(&mut self, buffer_size: usize) -> Result<VecDeque<Cat>, Terminate> {
[INFO] [stdout]     |                                                                   ^^^^^^^^ not found in this scope
[INFO] [stdout]     |
[INFO] [stdout] help: consider importing this struct
[INFO] [stdout]     |
[INFO] [stdout] 1   + use std::collections::VecDeque;
[INFO] [stdout]     |
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0412]: cannot find type `Terminate` in this scope
[INFO] [stdout]    --> examples/pulsar_batcher.rs:106:82
[INFO] [stdout]     |
[INFO] [stdout] 106 |     async fn fill_buffer(&mut self, buffer_size: usize) -> Result<VecDeque<Cat>, Terminate> {
[INFO] [stdout]     |                                                                                  ^^^^^^^^^ not found in this scope
[INFO] [stdout]     |
[INFO] [stdout] help: you might be missing a type parameter
[INFO] [stdout]     |
[INFO] [stdout] 98  | impl<Terminate> Producer<Cat> for Prod {
[INFO] [stdout]     |     +++++++++++
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0412]: cannot find type `VecDeque` in this scope
[INFO] [stdout]    --> examples/pulsar_batcher.rs:115:24
[INFO] [stdout]     |
[INFO] [stdout] 115 |             .collect::<VecDeque<Cat>>())
[INFO] [stdout]     |                        ^^^^^^^^ not found in this scope
[INFO] [stdout]     |
[INFO] [stdout] help: consider importing this struct
[INFO] [stdout]     |
[INFO] [stdout] 1   + use std::collections::VecDeque;
[INFO] [stdout]     |
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0405]: cannot find trait `Processor` in this scope
[INFO] [stdout]    --> examples/pulsar_batcher.rs:124:6
[INFO] [stdout]     |
[INFO] [stdout] 124 | impl Processor<Cat, Cat> for Layer1Process {
[INFO] [stdout]     |      ^^^^^^^^^ not found in this scope
[INFO] [stdout]     |
[INFO] [stdout] help: consider importing this trait
[INFO] [stdout]     |
[INFO] [stdout] 1   + use tokio_sky::Processor;
[INFO] [stdout]     |
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0412]: cannot find type `ProcResult` in this scope
[INFO] [stdout]    --> examples/pulsar_batcher.rs:128:54
[INFO] [stdout]     |
[INFO] [stdout] 128 |     async fn handle_message(&mut self, msg: Cat) ->  ProcResult<Cat> {
[INFO] [stdout]     |                                                      ^^^^^^^^^^ not found in this scope
[INFO] [stdout]     |
[INFO] [stdout] help: consider importing this enum
[INFO] [stdout]     |
[INFO] [stdout] 1   + use tokio_sky::ProcResult;
[INFO] [stdout]     |
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: failed to resolve: use of undeclared type `ProcResult`
[INFO] [stdout]    --> examples/pulsar_batcher.rs:131:9
[INFO] [stdout]     |
[INFO] [stdout] 131 |         ProcResult::Dispatch(msg,  None)
[INFO] [stdout]     |         ^^^^^^^^^^ use of undeclared type `ProcResult`
[INFO] [stdout]     |
[INFO] [stdout] help: consider importing this enum
[INFO] [stdout]     |
[INFO] [stdout] 1   + use tokio_sky::ProcResult;
[INFO] [stdout]     |
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: failed to resolve: use of undeclared type `RouterType`
[INFO] [stdout]   --> examples/ordering_and_paritioning.rs:11:27
[INFO] [stdout]    |
[INFO] [stdout] 11 |     let producer_router = RouterType::RoundRobin;
[INFO] [stdout]    |                           ^^^^^^^^^^ use of undeclared type `RouterType`
[INFO] [stdout]    |
[INFO] [stdout] help: consider importing this enum
[INFO] [stdout]    |
[INFO] [stdout] 1  + use tokio_sky::RouterType;
[INFO] [stdout]    |
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: failed to resolve: use of undeclared type `Collector`
[INFO] [stdout]   --> examples/collector.rs:11:31
[INFO] [stdout]    |
[INFO] [stdout] 11 |     let producer_factory = || Collector::new(collector_recv, timeout);
[INFO] [stdout]    |                               ^^^^^^^^^ use of undeclared type `Collector`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0425]: cannot find function `run_topology_1` in this scope
[INFO] [stdout]   --> examples/collector.rs:41:17
[INFO] [stdout]    |
[INFO] [stdout] 41 |                 run_topology_1(
[INFO] [stdout]    |                 ^^^^^^^^^^^^^^ not found in this scope
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error: aborting due to 12 previous errors
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] Some errors have detailed explanations: E0405, E0412, E0425, E0433, E0706.
[INFO] [stdout] 
[INFO] [stdout] For more information about an error, try `rustc --explain E0405`.
[INFO] [stdout] 
[INFO] [stdout] error[E0412]: cannot find type `VecDeque` in this scope
[INFO] [stdout]   --> examples/pulsar_processor.rs:97:67
[INFO] [stdout]    |
[INFO] [stdout] 97 |     async fn fill_buffer(&mut self, buffer_size: usize) -> Result<VecDeque<TestData>, Terminate> {
[INFO] [stdout]    |                                                                   ^^^^^^^^ not found in this scope
[INFO] [stdout]    |
[INFO] [stdout] help: consider importing this struct
[INFO] [stdout]    |
[INFO] [stdout] 1  + use std::collections::VecDeque;
[INFO] [stdout]    |
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0412]: cannot find type `Terminate` in this scope
[INFO] [stdout]   --> examples/pulsar_processor.rs:97:87
[INFO] [stdout]    |
[INFO] [stdout] 97 |     async fn fill_buffer(&mut self, buffer_size: usize) -> Result<VecDeque<TestData>, Terminate> {
[INFO] [stdout]    |                                                                                       ^^^^^^^^^ not found in this scope
[INFO] [stdout]    |
[INFO] [stdout] help: you might be missing a type parameter
[INFO] [stdout]    |
[INFO] [stdout] 89 | impl<Terminate> Producer<TestData> for Prod {
[INFO] [stdout]    |     +++++++++++
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0412]: cannot find type `VecDeque` in this scope
[INFO] [stdout]    --> examples/pulsar_processor.rs:106:24
[INFO] [stdout]     |
[INFO] [stdout] 106 |             .collect::<VecDeque<TestData>>())
[INFO] [stdout]     |                        ^^^^^^^^ not found in this scope
[INFO] [stdout]     |
[INFO] [stdout] help: consider importing this struct
[INFO] [stdout]     |
[INFO] [stdout] 1   + use std::collections::VecDeque;
[INFO] [stdout]     |
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: failed to resolve: use of undeclared type `RouterType`
[INFO] [stdout]   --> examples/ordering_and_paritioning.rs:17:24
[INFO] [stdout]    |
[INFO] [stdout] 17 |     let proc1_router = RouterType::Partition;
[INFO] [stdout]    |                        ^^^^^^^^^^ use of undeclared type `RouterType`
[INFO] [stdout]    |
[INFO] [stdout] help: consider importing this enum
[INFO] [stdout]    |
[INFO] [stdout] 1  + use tokio_sky::RouterType;
[INFO] [stdout]    |
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0405]: cannot find trait `Producer` in this scope
[INFO] [stdout]   --> examples/ordering_and_paritioning.rs:97:6
[INFO] [stdout]    |
[INFO] [stdout] 97 | impl Producer<User> for Prod {
[INFO] [stdout]    |      ^^^^^^^^ not found in this scope
[INFO] [stdout]    |
[INFO] [stdout] help: consider importing this trait
[INFO] [stdout]    |
[INFO] [stdout] 1  + use tokio_sky::Producer;
[INFO] [stdout]    |
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0412]: cannot find type `VecDeque` in this scope
[INFO] [stdout]    --> examples/ordering_and_paritioning.rs:102:40
[INFO] [stdout]     |
[INFO] [stdout] 102 |     async fn drain(&mut self, _buffer: VecDeque<User>) {}
[INFO] [stdout]     |                                        ^^^^^^^^ not found in this scope
[INFO] [stdout]     |
[INFO] [stdout] help: consider importing this struct
[INFO] [stdout]     |
[INFO] [stdout] 1   + use std::collections::VecDeque;
[INFO] [stdout]     |
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0412]: cannot find type `VecDeque` in this scope
[INFO] [stdout]    --> examples/ordering_and_paritioning.rs:105:67
[INFO] [stdout]     |
[INFO] [stdout] 105 |     async fn fill_buffer(&mut self, buffer_size: usize) -> Result<VecDeque<User>, Terminate> {
[INFO] [stdout]     |                                                                   ^^^^^^^^ not found in this scope
[INFO] [stdout]     |
[INFO] [stdout] help: consider importing this struct
[INFO] [stdout]     |
[INFO] [stdout] 1   + use std::collections::VecDeque;
[INFO] [stdout]     |
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0412]: cannot find type `Terminate` in this scope
[INFO] [stdout]    --> examples/ordering_and_paritioning.rs:105:83
[INFO] [stdout]     |
[INFO] [stdout] 105 |     async fn fill_buffer(&mut self, buffer_size: usize) -> Result<VecDeque<User>, Terminate> {
[INFO] [stdout]     |                                                                                   ^^^^^^^^^ not found in this scope
[INFO] [stdout]     |
[INFO] [stdout] help: you might be missing a type parameter
[INFO] [stdout]     |
[INFO] [stdout] 97  | impl<Terminate> Producer<User> for Prod {
[INFO] [stdout]     |     +++++++++++
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0412]: cannot find type `VecDeque` in this scope
[INFO] [stdout]    --> examples/ordering_and_paritioning.rs:115:24
[INFO] [stdout]     |
[INFO] [stdout] 115 |             .collect::<VecDeque<User>>())
[INFO] [stdout]     |                        ^^^^^^^^ not found in this scope
[INFO] [stdout]     |
[INFO] [stdout] help: consider importing this struct
[INFO] [stdout]     |
[INFO] [stdout] 1   + use std::collections::VecDeque;
[INFO] [stdout]     |
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0405]: cannot find trait `Processor` in this scope
[INFO] [stdout]    --> examples/ordering_and_paritioning.rs:122:6
[INFO] [stdout]     |
[INFO] [stdout] 122 | impl Processor<User, User> for Layer1Process {
[INFO] [stdout]     |      ^^^^^^^^^ not found in this scope
[INFO] [stdout]     |
[INFO] [stdout] help: consider importing this trait
[INFO] [stdout]     |
[INFO] [stdout] 1   + use tokio_sky::Processor;
[INFO] [stdout]     |
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0412]: cannot find type `ProcResult` in this scope
[INFO] [stdout]    --> examples/ordering_and_paritioning.rs:126:55
[INFO] [stdout]     |
[INFO] [stdout] 126 |     async fn handle_message(&mut self, msg: User) ->  ProcResult<User> {
[INFO] [stdout]     |                                                       ^^^^^^^^^^ not found in this scope
[INFO] [stdout]     |
[INFO] [stdout] help: consider importing this enum
[INFO] [stdout]     |
[INFO] [stdout] 1   + use tokio_sky::ProcResult;
[INFO] [stdout]     |
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: failed to resolve: use of undeclared type `ProcResult`
[INFO] [stdout]    --> examples/ordering_and_paritioning.rs:134:9
[INFO] [stdout]     |
[INFO] [stdout] 134 |         ProcResult::Dispatch(msg,  Some(pk))
[INFO] [stdout]     |         ^^^^^^^^^^ use of undeclared type `ProcResult`
[INFO] [stdout]     |
[INFO] [stdout] help: consider importing this enum
[INFO] [stdout]     |
[INFO] [stdout] 1   + use tokio_sky::ProcResult;
[INFO] [stdout]     |
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0405]: cannot find trait `Processor` in this scope
[INFO] [stdout]    --> examples/ordering_and_paritioning.rs:149:6
[INFO] [stdout]     |
[INFO] [stdout] 149 | impl Processor<User, ()> for Layer2Process {
[INFO] [stdout]     |      ^^^^^^^^^ not found in this scope
[INFO] [stdout]     |
[INFO] [stdout] help: consider importing this trait
[INFO] [stdout]     |
[INFO] [stdout] 1   + use tokio_sky::Processor;
[INFO] [stdout]     |
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0412]: cannot find type `ProcResult` in this scope
[INFO] [stdout]    --> examples/ordering_and_paritioning.rs:153:55
[INFO] [stdout]     |
[INFO] [stdout] 153 |     async fn handle_message(&mut self, msg: User) ->  ProcResult<()> {
[INFO] [stdout]     |                                                       ^^^^^^^^^^ not found in this scope
[INFO] [stdout]     |
[INFO] [stdout] help: consider importing this enum
[INFO] [stdout]     |
[INFO] [stdout] 1   + use tokio_sky::ProcResult;
[INFO] [stdout]     |
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: failed to resolve: use of undeclared type `ProcResult`
[INFO] [stdout]    --> examples/ordering_and_paritioning.rs:168:9
[INFO] [stdout]     |
[INFO] [stdout] 168 |         ProcResult::Continue
[INFO] [stdout]     |         ^^^^^^^^^^ use of undeclared type `ProcResult`
[INFO] [stdout]     |
[INFO] [stdout] help: consider importing this enum
[INFO] [stdout]     |
[INFO] [stdout] 1   + use tokio_sky::ProcResult;
[INFO] [stdout]     |
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0706]: functions in traits cannot be declared `async`
[INFO] [stdout]    --> examples/pulsar_batcher.rs:100:5
[INFO] [stdout]     |
[INFO] [stdout] 100 |     async fn init(&mut self) {}
[INFO] [stdout]     |     -----^^^^^^^^^^^^^^^^^^^
[INFO] [stdout]     |     |
[INFO] [stdout]     |     `async` because of this
[INFO] [stdout]     |
[INFO] [stdout]     = note: `async` trait functions are not currently supported
[INFO] [stdout]     = note: consider using the `async-trait` crate: https://crates.io/crates/async-trait
[INFO] [stdout]     = note: see issue #91611 <https://github.com/rust-lang/rust/issues/91611> for more information
[INFO] [stdout]     = help: add `#![feature(async_fn_in_trait)]` to the crate attributes to enable
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0706]: functions in traits cannot be declared `async`
[INFO] [stdout]    --> examples/pulsar_batcher.rs:102:5
[INFO] [stdout]     |
[INFO] [stdout] 102 |     async fn terminate(&mut self) {}
[INFO] [stdout]     |     -----^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout]     |     |
[INFO] [stdout]     |     `async` because of this
[INFO] [stdout]     |
[INFO] [stdout]     = note: `async` trait functions are not currently supported
[INFO] [stdout]     = note: consider using the `async-trait` crate: https://crates.io/crates/async-trait
[INFO] [stdout]     = note: see issue #91611 <https://github.com/rust-lang/rust/issues/91611> for more information
[INFO] [stdout]     = help: add `#![feature(async_fn_in_trait)]` to the crate attributes to enable
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0706]: functions in traits cannot be declared `async`
[INFO] [stdout]    --> examples/pulsar_batcher.rs:104:5
[INFO] [stdout]     |
[INFO] [stdout] 104 |     async fn drain(&mut self, _buffer: VecDeque<Cat>) {}
[INFO] [stdout]     |     -----^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout]     |     |
[INFO] [stdout]     |     `async` because of this
[INFO] [stdout]     |
[INFO] [stdout]     = note: `async` trait functions are not currently supported
[INFO] [stdout]     = note: consider using the `async-trait` crate: https://crates.io/crates/async-trait
[INFO] [stdout]     = note: see issue #91611 <https://github.com/rust-lang/rust/issues/91611> for more information
[INFO] [stdout]     = help: add `#![feature(async_fn_in_trait)]` to the crate attributes to enable
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0706]: functions in traits cannot be declared `async`
[INFO] [stdout]    --> examples/pulsar_batcher.rs:106:5
[INFO] [stdout]     |
[INFO] [stdout] 106 |     async fn fill_buffer(&mut self, buffer_size: usize) -> Result<VecDeque<Cat>, Terminate> {
[INFO] [stdout]     |     -----^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout]     |     |
[INFO] [stdout]     |     `async` because of this
[INFO] [stdout]     |
[INFO] [stdout]     = note: `async` trait functions are not currently supported
[INFO] [stdout]     = note: consider using the `async-trait` crate: https://crates.io/crates/async-trait
[INFO] [stdout]     = note: see issue #91611 <https://github.com/rust-lang/rust/issues/91611> for more information
[INFO] [stdout]     = help: add `#![feature(async_fn_in_trait)]` to the crate attributes to enable
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stderr] error: could not compile `tokio_sky` (example "collector") due to 13 previous errors
[INFO] [stdout] error[E0706]: functions in traits cannot be declared `async`
[INFO] [stdout]    --> examples/pulsar_batcher.rs:125:5
[INFO] [stdout]     |
[INFO] [stdout] 125 |     async fn init(&mut self) {}
[INFO] [stdout]     |     -----^^^^^^^^^^^^^^^^^^^
[INFO] [stdout]     |     |
[INFO] [stdout]     |     `async` because of this
[INFO] [stdout]     |
[INFO] [stdout]     = note: `async` trait functions are not currently supported
[INFO] [stdout]     = note: consider using the `async-trait` crate: https://crates.io/crates/async-trait
[INFO] [stdout]     = note: see issue #91611 <https://github.com/rust-lang/rust/issues/91611> for more information
[INFO] [stdout]     = help: add `#![feature(async_fn_in_trait)]` to the crate attributes to enable
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0706]: functions in traits cannot be declared `async`
[INFO] [stdout]    --> examples/pulsar_batcher.rs:126:5
[INFO] [stdout]     |
[INFO] [stdout] 126 |     async fn terminate(&mut self) {}
[INFO] [stdout]     |     -----^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout]     |     |
[INFO] [stdout]     |     `async` because of this
[INFO] [stdout]     |
[INFO] [stdout]     = note: `async` trait functions are not currently supported
[INFO] [stdout]     = note: consider using the `async-trait` crate: https://crates.io/crates/async-trait
[INFO] [stdout]     = note: see issue #91611 <https://github.com/rust-lang/rust/issues/91611> for more information
[INFO] [stdout]     = help: add `#![feature(async_fn_in_trait)]` to the crate attributes to enable
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0706]: functions in traits cannot be declared `async`
[INFO] [stdout]    --> examples/pulsar_batcher.rs:128:5
[INFO] [stdout]     |
[INFO] [stdout] 128 |     async fn handle_message(&mut self, msg: Cat) ->  ProcResult<Cat> {
[INFO] [stdout]     |     -----^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout]     |     |
[INFO] [stdout]     |     `async` because of this
[INFO] [stdout]     |
[INFO] [stdout]     = note: `async` trait functions are not currently supported
[INFO] [stdout]     = note: consider using the `async-trait` crate: https://crates.io/crates/async-trait
[INFO] [stdout]     = note: see issue #91611 <https://github.com/rust-lang/rust/issues/91611> for more information
[INFO] [stdout]     = help: add `#![feature(async_fn_in_trait)]` to the crate attributes to enable
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: failed to resolve: use of undeclared type `Pulsar`
[INFO] [stdout]   --> examples/pulsar_batcher.rs:26:29
[INFO] [stdout]    |
[INFO] [stdout] 26 |     let pulsar: Pulsar<_> = Pulsar::builder(addr, TokioExecutor).build().await.unwrap();
[INFO] [stdout]    |                             ^^^^^^ use of undeclared type `Pulsar`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0706]: functions in traits cannot be declared `async`
[INFO] [stdout]   --> examples/ordering_and_paritioning.rs:99:5
[INFO] [stdout]    |
[INFO] [stdout] 99 |     async fn init(&mut self) {}
[INFO] [stdout]    |     -----^^^^^^^^^^^^^^^^^^^
[INFO] [stdout]    |     |
[INFO] [stdout]    |     `async` because of this
[INFO] [stdout]    |
[INFO] [stdout]    = note: `async` trait functions are not currently supported
[INFO] [stdout]    = note: consider using the `async-trait` crate: https://crates.io/crates/async-trait
[INFO] [stdout]    = note: see issue #91611 <https://github.com/rust-lang/rust/issues/91611> for more information
[INFO] [stdout]    = help: add `#![feature(async_fn_in_trait)]` to the crate attributes to enable
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0706]: functions in traits cannot be declared `async`
[INFO] [stdout]    --> examples/ordering_and_paritioning.rs:100:5
[INFO] [stdout]     |
[INFO] [stdout] 100 |     async fn terminate(&mut self) {}
[INFO] [stdout]     |     -----^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout]     |     |
[INFO] [stdout]     |     `async` because of this
[INFO] [stdout]     |
[INFO] [stdout]     = note: `async` trait functions are not currently supported
[INFO] [stdout]     = note: consider using the `async-trait` crate: https://crates.io/crates/async-trait
[INFO] [stdout]     = note: see issue #91611 <https://github.com/rust-lang/rust/issues/91611> for more information
[INFO] [stdout]     = help: add `#![feature(async_fn_in_trait)]` to the crate attributes to enable
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0706]: functions in traits cannot be declared `async`
[INFO] [stdout]    --> examples/ordering_and_paritioning.rs:102:5
[INFO] [stdout]     |
[INFO] [stdout] 102 |     async fn drain(&mut self, _buffer: VecDeque<User>) {}
[INFO] [stdout]     |     -----^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout]     |     |
[INFO] [stdout]     |     `async` because of this
[INFO] [stdout]     |
[INFO] [stdout]     = note: `async` trait functions are not currently supported
[INFO] [stdout]     = note: consider using the `async-trait` crate: https://crates.io/crates/async-trait
[INFO] [stdout]     = note: see issue #91611 <https://github.com/rust-lang/rust/issues/91611> for more information
[INFO] [stdout]     = help: add `#![feature(async_fn_in_trait)]` to the crate attributes to enable
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0706]: functions in traits cannot be declared `async`
[INFO] [stdout]    --> examples/ordering_and_paritioning.rs:105:5
[INFO] [stdout]     |
[INFO] [stdout] 105 |     async fn fill_buffer(&mut self, buffer_size: usize) -> Result<VecDeque<User>, Terminate> {
[INFO] [stdout]     |     -----^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout]     |     |
[INFO] [stdout]     |     `async` because of this
[INFO] [stdout]     |
[INFO] [stdout]     = note: `async` trait functions are not currently supported
[INFO] [stdout]     = note: consider using the `async-trait` crate: https://crates.io/crates/async-trait
[INFO] [stdout]     = note: see issue #91611 <https://github.com/rust-lang/rust/issues/91611> for more information
[INFO] [stdout]     = help: add `#![feature(async_fn_in_trait)]` to the crate attributes to enable
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0706]: functions in traits cannot be declared `async`
[INFO] [stdout]    --> examples/ordering_and_paritioning.rs:123:5
[INFO] [stdout]     |
[INFO] [stdout] 123 |     async fn init(&mut self) {}
[INFO] [stdout]     |     -----^^^^^^^^^^^^^^^^^^^
[INFO] [stdout]     |     |
[INFO] [stdout]     |     `async` because of this
[INFO] [stdout]     |
[INFO] [stdout]     = note: `async` trait functions are not currently supported
[INFO] [stdout]     = note: consider using the `async-trait` crate: https://crates.io/crates/async-trait
[INFO] [stdout]     = note: see issue #91611 <https://github.com/rust-lang/rust/issues/91611> for more information
[INFO] [stdout]     = help: add `#![feature(async_fn_in_trait)]` to the crate attributes to enable
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0706]: functions in traits cannot be declared `async`
[INFO] [stdout]    --> examples/ordering_and_paritioning.rs:124:5
[INFO] [stdout]     |
[INFO] [stdout] 124 |     async fn terminate(&mut self) {}
[INFO] [stdout]     |     -----^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout]     |     |
[INFO] [stdout]     |     `async` because of this
[INFO] [stdout]     |
[INFO] [stdout]     = note: `async` trait functions are not currently supported
[INFO] [stdout]     = note: consider using the `async-trait` crate: https://crates.io/crates/async-trait
[INFO] [stdout]     = note: see issue #91611 <https://github.com/rust-lang/rust/issues/91611> for more information
[INFO] [stdout]     = help: add `#![feature(async_fn_in_trait)]` to the crate attributes to enable
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0706]: functions in traits cannot be declared `async`
[INFO] [stdout]    --> examples/ordering_and_paritioning.rs:126:5
[INFO] [stdout]     |
[INFO] [stdout] 126 |     async fn handle_message(&mut self, msg: User) ->  ProcResult<User> {
[INFO] [stdout]     |     -----^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout]     |     |
[INFO] [stdout]     |     `async` because of this
[INFO] [stdout]     |
[INFO] [stdout]     = note: `async` trait functions are not currently supported
[INFO] [stdout]     = note: consider using the `async-trait` crate: https://crates.io/crates/async-trait
[INFO] [stdout]     = note: see issue #91611 <https://github.com/rust-lang/rust/issues/91611> for more information
[INFO] [stdout]     = help: add `#![feature(async_fn_in_trait)]` to the crate attributes to enable
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0706]: functions in traits cannot be declared `async`
[INFO] [stdout]    --> examples/ordering_and_paritioning.rs:150:5
[INFO] [stdout]     |
[INFO] [stdout] 150 |     async fn init(&mut self) {}
[INFO] [stdout]     |     -----^^^^^^^^^^^^^^^^^^^
[INFO] [stdout]     |     |
[INFO] [stdout]     |     `async` because of this
[INFO] [stdout]     |
[INFO] [stdout]     = note: `async` trait functions are not currently supported
[INFO] [stdout]     = note: consider using the `async-trait` crate: https://crates.io/crates/async-trait
[INFO] [stdout]     = note: see issue #91611 <https://github.com/rust-lang/rust/issues/91611> for more information
[INFO] [stdout]     = help: add `#![feature(async_fn_in_trait)]` to the crate attributes to enable
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0706]: functions in traits cannot be declared `async`
[INFO] [stdout]    --> examples/ordering_and_paritioning.rs:151:5
[INFO] [stdout]     |
[INFO] [stdout] 151 |     async fn terminate(&mut self) {}
[INFO] [stdout]     |     -----^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout]     |     |
[INFO] [stdout]     |     `async` because of this
[INFO] [stdout]     |
[INFO] [stdout]     = note: `async` trait functions are not currently supported
[INFO] [stdout]     = note: consider using the `async-trait` crate: https://crates.io/crates/async-trait
[INFO] [stdout]     = note: see issue #91611 <https://github.com/rust-lang/rust/issues/91611> for more information
[INFO] [stdout]     = help: add `#![feature(async_fn_in_trait)]` to the crate attributes to enable
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0706]: functions in traits cannot be declared `async`
[INFO] [stdout]    --> examples/ordering_and_paritioning.rs:153:5
[INFO] [stdout]     |
[INFO] [stdout] 153 |     async fn handle_message(&mut self, msg: User) ->  ProcResult<()> {
[INFO] [stdout]     |     -----^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout]     |     |
[INFO] [stdout]     |     `async` because of this
[INFO] [stdout]     |
[INFO] [stdout]     = note: `async` trait functions are not currently supported
[INFO] [stdout]     = note: consider using the `async-trait` crate: https://crates.io/crates/async-trait
[INFO] [stdout]     = note: see issue #91611 <https://github.com/rust-lang/rust/issues/91611> for more information
[INFO] [stdout]     = help: add `#![feature(async_fn_in_trait)]` to the crate attributes to enable
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0706]: functions in traits cannot be declared `async`
[INFO] [stdout]   --> examples/pulsar_processor.rs:91:5
[INFO] [stdout]    |
[INFO] [stdout] 91 |     async fn init(&mut self) {}
[INFO] [stdout]    |     -----^^^^^^^^^^^^^^^^^^^
[INFO] [stdout]    |     |
[INFO] [stdout]    |     `async` because of this
[INFO] [stdout]    |
[INFO] [stdout]    = note: `async` trait functions are not currently supported
[INFO] [stdout]    = note: consider using the `async-trait` crate: https://crates.io/crates/async-trait
[INFO] [stdout]    = note: see issue #91611 <https://github.com/rust-lang/rust/issues/91611> for more information
[INFO] [stdout]    = help: add `#![feature(async_fn_in_trait)]` to the crate attributes to enable
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: failed to resolve: use of undeclared type `RouterType`
[INFO] [stdout]   --> examples/dynamic_batching.rs:10:27
[INFO] [stdout]    |
[INFO] [stdout] 10 |     let producer_router = RouterType::RoundRobin;
[INFO] [stdout]    |                           ^^^^^^^^^^ use of undeclared type `RouterType`
[INFO] [stdout]    |
[INFO] [stdout] help: consider importing this enum
[INFO] [stdout]    |
[INFO] [stdout] 2  + use tokio_sky::RouterType;
[INFO] [stdout]    |
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: failed to resolve: use of undeclared type `RouterType`
[INFO] [stdout]   --> examples/dynamic_batching.rs:16:23
[INFO] [stdout]    |
[INFO] [stdout] 16 |     let proc_router = RouterType::Partition;
[INFO] [stdout]    |                       ^^^^^^^^^^ use of undeclared type `RouterType`
[INFO] [stdout]    |
[INFO] [stdout] help: consider importing this enum
[INFO] [stdout]    |
[INFO] [stdout] 2  + use tokio_sky::RouterType;
[INFO] [stdout]    |
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0405]: cannot find trait `Producer` in this scope
[INFO] [stdout]   --> examples/dynamic_batching.rs:78:6
[INFO] [stdout]    |
[INFO] [stdout] 78 | impl Producer<Product> for Prod {
[INFO] [stdout]    |      ^^^^^^^^ not found in this scope
[INFO] [stdout]    |
[INFO] [stdout] help: consider importing this trait
[INFO] [stdout]    |
[INFO] [stdout] 2  + use tokio_sky::Producer;
[INFO] [stdout]    |
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0412]: cannot find type `VecDeque` in this scope
[INFO] [stdout]   --> examples/dynamic_batching.rs:83:40
[INFO] [stdout]    |
[INFO] [stdout] 83 |     async fn drain(&mut self, _buffer: VecDeque<Product>) {}
[INFO] [stdout]    |                                        ^^^^^^^^ not found in this scope
[INFO] [stdout]    |
[INFO] [stdout] help: consider importing this struct
[INFO] [stdout]    |
[INFO] [stdout] 2  + use std::collections::VecDeque;
[INFO] [stdout]    |
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0412]: cannot find type `VecDeque` in this scope
[INFO] [stdout]   --> examples/dynamic_batching.rs:86:67
[INFO] [stdout]    |
[INFO] [stdout] 86 |     async fn fill_buffer(&mut self, buffer_size: usize) -> Result<VecDeque<Product>, Terminate> {
[INFO] [stdout]    |                                                                   ^^^^^^^^ not found in this scope
[INFO] [stdout]    |
[INFO] [stdout] help: consider importing this struct
[INFO] [stdout]    |
[INFO] [stdout] 2  + use std::collections::VecDeque;
[INFO] [stdout]    |
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0412]: cannot find type `Terminate` in this scope
[INFO] [stdout]   --> examples/dynamic_batching.rs:86:86
[INFO] [stdout]    |
[INFO] [stdout] 86 |     async fn fill_buffer(&mut self, buffer_size: usize) -> Result<VecDeque<Product>, Terminate> {
[INFO] [stdout]    |                                                                                      ^^^^^^^^^ not found in this scope
[INFO] [stdout]    |
[INFO] [stdout] help: you might be missing a type parameter
[INFO] [stdout]    |
[INFO] [stdout] 78 | impl<Terminate> Producer<Product> for Prod {
[INFO] [stdout]    |     +++++++++++
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0412]: cannot find type `VecDeque` in this scope
[INFO] [stdout]    --> examples/dynamic_batching.rs:104:24
[INFO] [stdout]     |
[INFO] [stdout] 104 |             .collect::<VecDeque<Product>>())
[INFO] [stdout]     |                        ^^^^^^^^ not found in this scope
[INFO] [stdout]     |
[INFO] [stdout] help: consider importing this struct
[INFO] [stdout]     |
[INFO] [stdout] 2   + use std::collections::VecDeque;
[INFO] [stdout]     |
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0405]: cannot find trait `Processor` in this scope
[INFO] [stdout]    --> examples/dynamic_batching.rs:111:6
[INFO] [stdout]     |
[INFO] [stdout] 111 | impl Processor<Product, Product> for Layer1Process {
[INFO] [stdout]     |      ^^^^^^^^^ not found in this scope
[INFO] [stdout]     |
[INFO] [stdout] help: consider importing this trait
[INFO] [stdout]     |
[INFO] [stdout] 2   + use tokio_sky::Processor;
[INFO] [stdout]     |
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0412]: cannot find type `ProcResult` in this scope
[INFO] [stdout]    --> examples/dynamic_batching.rs:115:58
[INFO] [stdout]     |
[INFO] [stdout] 115 |     async fn handle_message(&mut self, msg: Product) ->  ProcResult<Product> {
[INFO] [stdout]     |                                                          ^^^^^^^^^^ not found in this scope
[INFO] [stdout]     |
[INFO] [stdout] help: consider importing this enum
[INFO] [stdout]     |
[INFO] [stdout] 2   + use tokio_sky::ProcResult;
[INFO] [stdout]     |
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: failed to resolve: use of undeclared type `ProcResult`
[INFO] [stdout]    --> examples/dynamic_batching.rs:124:9
[INFO] [stdout]     |
[INFO] [stdout] 124 |         ProcResult::Dispatch(msg,  Some(pk))
[INFO] [stdout]     |         ^^^^^^^^^^ use of undeclared type `ProcResult`
[INFO] [stdout]     |
[INFO] [stdout] help: consider importing this enum
[INFO] [stdout]     |
[INFO] [stdout] 2   + use tokio_sky::ProcResult;
[INFO] [stdout]     |
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0412]: cannot find type `BatcherTerminate` in this scope
[INFO] [stdout]    --> examples/dynamic_batching.rs:148:73
[INFO] [stdout]     |
[INFO] [stdout] 148 |     async fn handle_batch(&mut self, batch: Vec<Product>) -> Result<(), BatcherTerminate<Input>> {
[INFO] [stdout]     |                                                                         ^^^^^^^^^^^^^^^^ not found in this scope
[INFO] [stdout]     |
[INFO] [stdout] help: consider importing this struct
[INFO] [stdout]     |
[INFO] [stdout] 2   + use tokio_sky::BatcherTerminate;
[INFO] [stdout]     |
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0412]: cannot find type `Input` in this scope
[INFO] [stdout]    --> examples/dynamic_batching.rs:148:90
[INFO] [stdout]     |
[INFO] [stdout] 148 |     async fn handle_batch(&mut self, batch: Vec<Product>) -> Result<(), BatcherTerminate<Input>> {
[INFO] [stdout]     |                                                                                          ^^^^^ not found in this scope
[INFO] [stdout]     |
[INFO] [stdout] help: you might be missing a type parameter
[INFO] [stdout]     |
[INFO] [stdout] 142 | impl<Input> BatchProcessor<Product, ()> for Batcher {
[INFO] [stdout]     |     +++++++
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: failed to resolve: use of undeclared type `ProcResult`
[INFO] [stdout]    --> examples/dynamic_batching.rs:168:9
[INFO] [stdout]     |
[INFO] [stdout] 168 |         ProcResult::Continue
[INFO] [stdout]     |         ^^^^^^^^^^ use of undeclared type `ProcResult`
[INFO] [stdout]     |
[INFO] [stdout] help: consider importing this enum
[INFO] [stdout]     |
[INFO] [stdout] 2   + use tokio_sky::ProcResult;
[INFO] [stdout]     |
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: failed to resolve: use of undeclared type `RouterType`
[INFO] [stdout]  --> examples/batch_insert_mysql.rs:9:27
[INFO] [stdout]   |
[INFO] [stdout] 9 |     let producer_router = RouterType::RoundRobin;
[INFO] [stdout]   |                           ^^^^^^^^^^ use of undeclared type `RouterType`
[INFO] [stdout]   |
[INFO] [stdout] help: consider importing this enum
[INFO] [stdout]   |
[INFO] [stdout] 1 + use tokio_sky::RouterType;
[INFO] [stdout]   |
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0706]: functions in traits cannot be declared `async`
[INFO] [stdout]   --> examples/pulsar_processor.rs:93:5
[INFO] [stdout]    |
[INFO] [stdout] 93 |     async fn terminate(&mut self) {}
[INFO] [stdout]    |     -----^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout]    |     |
[INFO] [stdout]    |     `async` because of this
[INFO] [stdout]    |
[INFO] [stdout]    = note: `async` trait functions are not currently supported
[INFO] [stdout]    = note: consider using the `async-trait` crate: https://crates.io/crates/async-trait
[INFO] [stdout]    = note: see issue #91611 <https://github.com/rust-lang/rust/issues/91611> for more information
[INFO] [stdout]    = help: add `#![feature(async_fn_in_trait)]` to the crate attributes to enable
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0706]: functions in traits cannot be declared `async`
[INFO] [stdout]   --> examples/pulsar_processor.rs:95:5
[INFO] [stdout]    |
[INFO] [stdout] 95 |     async fn drain(&mut self, _buffer: VecDeque<TestData>) {}
[INFO] [stdout]    |     -----^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout]    |     |
[INFO] [stdout]    |     `async` because of this
[INFO] [stdout]    |
[INFO] [stdout]    = note: `async` trait functions are not currently supported
[INFO] [stdout]    = note: consider using the `async-trait` crate: https://crates.io/crates/async-trait
[INFO] [stdout]    = note: see issue #91611 <https://github.com/rust-lang/rust/issues/91611> for more information
[INFO] [stdout]    = help: add `#![feature(async_fn_in_trait)]` to the crate attributes to enable
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0706]: functions in traits cannot be declared `async`
[INFO] [stdout]   --> examples/dynamic_batching.rs:80:5
[INFO] [stdout]    |
[INFO] [stdout] 80 |     async fn init(&mut self) {}
[INFO] [stdout]    |     -----^^^^^^^^^^^^^^^^^^^
[INFO] [stdout]    |     |
[INFO] [stdout]    |     `async` because of this
[INFO] [stdout]    |
[INFO] [stdout]    = note: `async` trait functions are not currently supported
[INFO] [stdout]    = note: consider using the `async-trait` crate: https://crates.io/crates/async-trait
[INFO] [stdout]    = note: see issue #91611 <https://github.com/rust-lang/rust/issues/91611> for more information
[INFO] [stdout]    = help: add `#![feature(async_fn_in_trait)]` to the crate attributes to enable
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: failed to resolve: use of undeclared crate or module `proto`
[INFO] [stdout]   --> examples/pulsar_batcher.rs:28:22
[INFO] [stdout]    |
[INFO] [stdout] 28 |         schema: Some(proto::Schema {
[INFO] [stdout]    |                      ^^^^^ use of undeclared crate or module `proto`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0706]: functions in traits cannot be declared `async`
[INFO] [stdout]   --> examples/pulsar_processor.rs:97:5
[INFO] [stdout]    |
[INFO] [stdout] 97 |     async fn fill_buffer(&mut self, buffer_size: usize) -> Result<VecDeque<TestData>, Terminate> {
[INFO] [stdout]    |     -----^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout]    |     |
[INFO] [stdout]    |     `async` because of this
[INFO] [stdout]    |
[INFO] [stdout]    = note: `async` trait functions are not currently supported
[INFO] [stdout]    = note: consider using the `async-trait` crate: https://crates.io/crates/async-trait
[INFO] [stdout]    = note: see issue #91611 <https://github.com/rust-lang/rust/issues/91611> for more information
[INFO] [stdout]    = help: add `#![feature(async_fn_in_trait)]` to the crate attributes to enable
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0706]: functions in traits cannot be declared `async`
[INFO] [stdout]   --> examples/dynamic_batching.rs:81:5
[INFO] [stdout]    |
[INFO] [stdout] 81 |     async fn terminate(&mut self) {}
[INFO] [stdout]    |     -----^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout]    |     |
[INFO] [stdout]    |     `async` because of this
[INFO] [stdout]    |
[INFO] [stdout]    = note: `async` trait functions are not currently supported
[INFO] [stdout]    = note: consider using the `async-trait` crate: https://crates.io/crates/async-trait
[INFO] [stdout]    = note: see issue #91611 <https://github.com/rust-lang/rust/issues/91611> for more information
[INFO] [stdout]    = help: add `#![feature(async_fn_in_trait)]` to the crate attributes to enable
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: failed to resolve: use of undeclared crate or module `producer`
[INFO] [stdout]   --> examples/pulsar_batcher.rs:85:49
[INFO] [stdout]    |
[INFO] [stdout] 85 |     fn serialize_message(input: Self) -> Result<producer::Message, PulsarError> {
[INFO] [stdout]    |                                                 ^^^^^^^^ use of undeclared crate or module `producer`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0706]: functions in traits cannot be declared `async`
[INFO] [stdout]   --> examples/dynamic_batching.rs:83:5
[INFO] [stdout]    |
[INFO] [stdout] 83 |     async fn drain(&mut self, _buffer: VecDeque<Product>) {}
[INFO] [stdout]    |     -----^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout]    |     |
[INFO] [stdout]    |     `async` because of this
[INFO] [stdout]    |
[INFO] [stdout]    = note: `async` trait functions are not currently supported
[INFO] [stdout]    = note: consider using the `async-trait` crate: https://crates.io/crates/async-trait
[INFO] [stdout]    = note: see issue #91611 <https://github.com/rust-lang/rust/issues/91611> for more information
[INFO] [stdout]    = help: add `#![feature(async_fn_in_trait)]` to the crate attributes to enable
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: failed to resolve: use of undeclared crate or module `serde_json`
[INFO] [stdout]   --> examples/pulsar_batcher.rs:86:23
[INFO] [stdout]    |
[INFO] [stdout] 86 |         let payload = serde_json::to_vec(&input).map_err(|e| PulsarError::Custom(e.to_string()))?;
[INFO] [stdout]    |                       ^^^^^^^^^^ use of undeclared crate or module `serde_json`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: failed to resolve: use of undeclared type `PulsarError`
[INFO] [stdout]   --> examples/pulsar_batcher.rs:86:62
[INFO] [stdout]    |
[INFO] [stdout] 86 |         let payload = serde_json::to_vec(&input).map_err(|e| PulsarError::Custom(e.to_string()))?;
[INFO] [stdout]    |                                                              ^^^^^^^^^^^ use of undeclared type `PulsarError`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: failed to resolve: use of undeclared crate or module `producer`
[INFO] [stdout]   --> examples/pulsar_batcher.rs:87:12
[INFO] [stdout]    |
[INFO] [stdout] 87 |         Ok(producer::Message {
[INFO] [stdout]    |            ^^^^^^^^ use of undeclared crate or module `producer`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0706]: functions in traits cannot be declared `async`
[INFO] [stdout]   --> examples/dynamic_batching.rs:86:5
[INFO] [stdout]    |
[INFO] [stdout] 86 |     async fn fill_buffer(&mut self, buffer_size: usize) -> Result<VecDeque<Product>, Terminate> {
[INFO] [stdout]    |     -----^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout]    |     |
[INFO] [stdout]    |     `async` because of this
[INFO] [stdout]    |
[INFO] [stdout]    = note: `async` trait functions are not currently supported
[INFO] [stdout]    = note: consider using the `async-trait` crate: https://crates.io/crates/async-trait
[INFO] [stdout]    = note: see issue #91611 <https://github.com/rust-lang/rust/issues/91611> for more information
[INFO] [stdout]    = help: add `#![feature(async_fn_in_trait)]` to the crate attributes to enable
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0425]: cannot find function `run_topology_1_with_batcher` in this scope
[INFO] [stdout]   --> examples/pulsar_batcher.rs:51:17
[INFO] [stdout]    |
[INFO] [stdout] 51 |                 run_topology_1_with_batcher(
[INFO] [stdout]    |                 ^^^^^^^^^^^^^^^^^^^^^^^^^^^ not found in this scope
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error: aborting due to 40 previous errors
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] Some errors have detailed explanations: E0405, E0412, E0425, E0432, E0433, E0706.
[INFO] [stdout] 
[INFO] [stdout] For more information about an error, try `rustc --explain E0405`.
[INFO] [stdout] 
[INFO] [stdout] error[E0706]: functions in traits cannot be declared `async`
[INFO] [stdout]    --> examples/dynamic_batching.rs:112:5
[INFO] [stdout]     |
[INFO] [stdout] 112 |     async fn init(&mut self) {}
[INFO] [stdout]     |     -----^^^^^^^^^^^^^^^^^^^
[INFO] [stdout]     |     |
[INFO] [stdout]     |     `async` because of this
[INFO] [stdout]     |
[INFO] [stdout]     = note: `async` trait functions are not currently supported
[INFO] [stdout]     = note: consider using the `async-trait` crate: https://crates.io/crates/async-trait
[INFO] [stdout]     = note: see issue #91611 <https://github.com/rust-lang/rust/issues/91611> for more information
[INFO] [stdout]     = help: add `#![feature(async_fn_in_trait)]` to the crate attributes to enable
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0706]: functions in traits cannot be declared `async`
[INFO] [stdout]    --> examples/dynamic_batching.rs:113:5
[INFO] [stdout]     |
[INFO] [stdout] 113 |     async fn terminate(&mut self) {}
[INFO] [stdout]     |     -----^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout]     |     |
[INFO] [stdout]     |     `async` because of this
[INFO] [stdout]     |
[INFO] [stdout]     = note: `async` trait functions are not currently supported
[INFO] [stdout]     = note: consider using the `async-trait` crate: https://crates.io/crates/async-trait
[INFO] [stdout]     = note: see issue #91611 <https://github.com/rust-lang/rust/issues/91611> for more information
[INFO] [stdout]     = help: add `#![feature(async_fn_in_trait)]` to the crate attributes to enable
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0706]: functions in traits cannot be declared `async`
[INFO] [stdout]    --> examples/dynamic_batching.rs:115:5
[INFO] [stdout]     |
[INFO] [stdout] 115 |     async fn handle_message(&mut self, msg: Product) ->  ProcResult<Product> {
[INFO] [stdout]     |     -----^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout]     |     |
[INFO] [stdout]     |     `async` because of this
[INFO] [stdout]     |
[INFO] [stdout]     = note: `async` trait functions are not currently supported
[INFO] [stdout]     = note: consider using the `async-trait` crate: https://crates.io/crates/async-trait
[INFO] [stdout]     = note: see issue #91611 <https://github.com/rust-lang/rust/issues/91611> for more information
[INFO] [stdout]     = help: add `#![feature(async_fn_in_trait)]` to the crate attributes to enable
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: failed to resolve: use of undeclared type `Pulsar`
[INFO] [stdout]   --> examples/pulsar_processor.rs:18:29
[INFO] [stdout]    |
[INFO] [stdout] 18 |     let pulsar: Pulsar<_> = Pulsar::builder(addr, TokioExecutor).build().await.unwrap();
[INFO] [stdout]    |                             ^^^^^^ use of undeclared type `Pulsar`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stderr] error: could not compile `tokio_sky` (example "pulsar_batcher") due to 41 previous errors
[INFO] [stdout] error[E0706]: functions in traits cannot be declared `async`
[INFO] [stdout]    --> examples/dynamic_batching.rs:143:5
[INFO] [stdout]     |
[INFO] [stdout] 143 |     async fn init(&mut self) {}
[INFO] [stdout]     |     -----^^^^^^^^^^^^^^^^^^^
[INFO] [stdout]     |     |
[INFO] [stdout]     |     `async` because of this
[INFO] [stdout]     |
[INFO] [stdout]     = note: `async` trait functions are not currently supported
[INFO] [stdout]     = note: consider using the `async-trait` crate: https://crates.io/crates/async-trait
[INFO] [stdout]     = note: see issue #91611 <https://github.com/rust-lang/rust/issues/91611> for more information
[INFO] [stdout]     = help: add `#![feature(async_fn_in_trait)]` to the crate attributes to enable
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0706]: functions in traits cannot be declared `async`
[INFO] [stdout]    --> examples/dynamic_batching.rs:144:5
[INFO] [stdout]     |
[INFO] [stdout] 144 |     async fn terminate(&mut self) {}
[INFO] [stdout]     |     -----^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout]     |     |
[INFO] [stdout]     |     `async` because of this
[INFO] [stdout]     |
[INFO] [stdout]     = note: `async` trait functions are not currently supported
[INFO] [stdout]     = note: consider using the `async-trait` crate: https://crates.io/crates/async-trait
[INFO] [stdout]     = note: see issue #91611 <https://github.com/rust-lang/rust/issues/91611> for more information
[INFO] [stdout]     = help: add `#![feature(async_fn_in_trait)]` to the crate attributes to enable
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: failed to resolve: use of undeclared crate or module `producer`
[INFO] [stdout]   --> examples/pulsar_processor.rs:19:16
[INFO] [stdout]    |
[INFO] [stdout] 19 |     let opts = producer::ProducerOptions {
[INFO] [stdout]    |                ^^^^^^^^ use of undeclared crate or module `producer`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: failed to resolve: use of undeclared crate or module `proto`
[INFO] [stdout]   --> examples/pulsar_processor.rs:20:22
[INFO] [stdout]    |
[INFO] [stdout] 20 |         schema: Some(proto::Schema {
[INFO] [stdout]    |                      ^^^^^ use of undeclared crate or module `proto`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0706]: functions in traits cannot be declared `async`
[INFO] [stdout]    --> examples/dynamic_batching.rs:146:5
[INFO] [stdout]     |
[INFO] [stdout] 146 |     async fn drain(&mut self, batch: Vec<Product>);
[INFO] [stdout]     |     -----^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout]     |     |
[INFO] [stdout]     |     `async` because of this
[INFO] [stdout]     |
[INFO] [stdout]     = note: `async` trait functions are not currently supported
[INFO] [stdout]     = note: consider using the `async-trait` crate: https://crates.io/crates/async-trait
[INFO] [stdout]     = note: see issue #91611 <https://github.com/rust-lang/rust/issues/91611> for more information
[INFO] [stdout]     = help: add `#![feature(async_fn_in_trait)]` to the crate attributes to enable
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: failed to resolve: use of undeclared crate or module `producer`
[INFO] [stdout]   --> examples/pulsar_processor.rs:76:49
[INFO] [stdout]    |
[INFO] [stdout] 76 |     fn serialize_message(input: Self) -> Result<producer::Message, PulsarError> {
[INFO] [stdout]    |                                                 ^^^^^^^^ use of undeclared crate or module `producer`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: failed to resolve: use of undeclared crate or module `serde_json`
[INFO] [stdout]   --> examples/pulsar_processor.rs:77:23
[INFO] [stdout]    |
[INFO] [stdout] 77 |         let payload = serde_json::to_vec(&input).map_err(|e| PulsarError::Custom(e.to_string()))?;
[INFO] [stdout]    |                       ^^^^^^^^^^ use of undeclared crate or module `serde_json`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: failed to resolve: use of undeclared type `PulsarError`
[INFO] [stdout]   --> examples/pulsar_processor.rs:77:62
[INFO] [stdout]    |
[INFO] [stdout] 77 |         let payload = serde_json::to_vec(&input).map_err(|e| PulsarError::Custom(e.to_string()))?;
[INFO] [stdout]    |                                                              ^^^^^^^^^^^ use of undeclared type `PulsarError`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: failed to resolve: use of undeclared crate or module `producer`
[INFO] [stdout]   --> examples/pulsar_processor.rs:78:12
[INFO] [stdout]    |
[INFO] [stdout] 78 |         Ok(producer::Message {
[INFO] [stdout]    |            ^^^^^^^^ use of undeclared crate or module `producer`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0706]: functions in traits cannot be declared `async`
[INFO] [stdout]    --> examples/dynamic_batching.rs:148:5
[INFO] [stdout]     |
[INFO] [stdout] 148 |     async fn handle_batch(&mut self, batch: Vec<Product>) -> Result<(), BatcherTerminate<Input>> {
[INFO] [stdout]     |     -----^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout]     |     |
[INFO] [stdout]     |     `async` because of this
[INFO] [stdout]     |
[INFO] [stdout]     = note: `async` trait functions are not currently supported
[INFO] [stdout]     = note: consider using the `async-trait` crate: https://crates.io/crates/async-trait
[INFO] [stdout]     = note: see issue #91611 <https://github.com/rust-lang/rust/issues/91611> for more information
[INFO] [stdout]     = help: add `#![feature(async_fn_in_trait)]` to the crate attributes to enable
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0425]: cannot find function `run_topology_1` in this scope
[INFO] [stdout]   --> examples/pulsar_processor.rs:52:17
[INFO] [stdout]    |
[INFO] [stdout] 52 |                 run_topology_1(
[INFO] [stdout]    |                 ^^^^^^^^^^^^^^ not found in this scope
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error: aborting due to 27 previous errors
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] Some errors have detailed explanations: E0405, E0412, E0425, E0432, E0433, E0706.
[INFO] [stdout] 
[INFO] [stdout] For more information about an error, try `rustc --explain E0405`.
[INFO] [stdout] 
[INFO] [stdout] error: aborting due to 30 previous errors
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] Some errors have detailed explanations: E0405, E0412, E0432, E0433, E0706.
[INFO] [stdout] 
[INFO] [stdout] For more information about an error, try `rustc --explain E0405`.
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: failed to resolve: use of undeclared type `RouterType`
[INFO] [stdout]   --> examples/batch_insert_mysql.rs:15:23
[INFO] [stdout]    |
[INFO] [stdout] 15 |     let proc_router = RouterType::Partition;
[INFO] [stdout]    |                       ^^^^^^^^^^ use of undeclared type `RouterType`
[INFO] [stdout]    |
[INFO] [stdout] help: consider importing this enum
[INFO] [stdout]    |
[INFO] [stdout] 1  + use tokio_sky::RouterType;
[INFO] [stdout]    |
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0412]: cannot find type `BATCH_TIMEOUT` in this scope
[INFO] [stdout]   --> examples/batch_insert_mysql.rs:28:32
[INFO] [stdout]    |
[INFO] [stdout] 28 |     let batcher_batch_timeout: BATCH_TIMEOUT;
[INFO] [stdout]    |                                ^^^^^^^^^^^^^ not found in this scope
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0405]: cannot find trait `Producer` in this scope
[INFO] [stdout]   --> examples/batch_insert_mysql.rs:74:6
[INFO] [stdout]    |
[INFO] [stdout] 74 | impl Producer<User> for Prod {
[INFO] [stdout]    |      ^^^^^^^^ not found in this scope
[INFO] [stdout]    |
[INFO] [stdout] help: consider importing this trait
[INFO] [stdout]    |
[INFO] [stdout] 1  + use tokio_sky::Producer;
[INFO] [stdout]    |
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0412]: cannot find type `VecDeque` in this scope
[INFO] [stdout]   --> examples/batch_insert_mysql.rs:80:40
[INFO] [stdout]    |
[INFO] [stdout] 80 |     async fn drain(&mut self, _buffer: VecDeque<User>) {}
[INFO] [stdout]    |                                        ^^^^^^^^ not found in this scope
[INFO] [stdout]    |
[INFO] [stdout] help: consider importing this struct
[INFO] [stdout]    |
[INFO] [stdout] 1  + use std::collections::VecDeque;
[INFO] [stdout]    |
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0412]: cannot find type `VecDeque` in this scope
[INFO] [stdout]   --> examples/batch_insert_mysql.rs:82:67
[INFO] [stdout]    |
[INFO] [stdout] 82 |     async fn fill_buffer(&mut self, buffer_size: usize) -> Result<VecDeque<User>, Terminate> {
[INFO] [stdout]    |                                                                   ^^^^^^^^ not found in this scope
[INFO] [stdout]    |
[INFO] [stdout] help: consider importing this struct
[INFO] [stdout]    |
[INFO] [stdout] 1  + use std::collections::VecDeque;
[INFO] [stdout]    |
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0412]: cannot find type `Terminate` in this scope
[INFO] [stdout]   --> examples/batch_insert_mysql.rs:82:83
[INFO] [stdout]    |
[INFO] [stdout] 82 |     async fn fill_buffer(&mut self, buffer_size: usize) -> Result<VecDeque<User>, Terminate> {
[INFO] [stdout]    |                                                                                   ^^^^^^^^^ not found in this scope
[INFO] [stdout]    |
[INFO] [stdout] help: you might be missing a type parameter
[INFO] [stdout]    |
[INFO] [stdout] 74 | impl<Terminate> Producer<User> for Prod {
[INFO] [stdout]    |     +++++++++++
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0412]: cannot find type `VecDeque` in this scope
[INFO] [stdout]   --> examples/batch_insert_mysql.rs:92:24
[INFO] [stdout]    |
[INFO] [stdout] 92 |             .collect::<VecDeque<User>>())
[INFO] [stdout]    |                        ^^^^^^^^ not found in this scope
[INFO] [stdout]    |
[INFO] [stdout] help: consider importing this struct
[INFO] [stdout]    |
[INFO] [stdout] 1  + use std::collections::VecDeque;
[INFO] [stdout]    |
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error: aborting due to 27 previous errors
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] Some errors have detailed explanations: E0405, E0412, E0432, E0433, E0706.
[INFO] [stdout] 
[INFO] [stdout] For more information about an error, try `rustc --explain E0405`.
[INFO] [stdout] 
[INFO] [stdout] error[E0405]: cannot find trait `Processor` in this scope
[INFO] [stdout]    --> examples/batch_insert_mysql.rs:101:6
[INFO] [stdout]     |
[INFO] [stdout] 101 | impl Processor<User, User> for Layer1Process {
[INFO] [stdout]     |      ^^^^^^^^^ not found in this scope
[INFO] [stdout]     |
[INFO] [stdout] help: consider importing this trait
[INFO] [stdout]     |
[INFO] [stdout] 1   + use tokio_sky::Processor;
[INFO] [stdout]     |
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0412]: cannot find type `ProcResult` in this scope
[INFO] [stdout]    --> examples/batch_insert_mysql.rs:105:55
[INFO] [stdout]     |
[INFO] [stdout] 105 |     async fn handle_message(&mut self, msg: User) ->  ProcResult<User> {
[INFO] [stdout]     |                                                       ^^^^^^^^^^ not found in this scope
[INFO] [stdout]     |
[INFO] [stdout] help: consider importing this enum
[INFO] [stdout]     |
[INFO] [stdout] 1   + use tokio_sky::ProcResult;
[INFO] [stdout]     |
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: failed to resolve: use of undeclared type `ProcResult`
[INFO] [stdout]    --> examples/batch_insert_mysql.rs:111:9
[INFO] [stdout]     |
[INFO] [stdout] 111 |         ProcResult::Dispatch(msg, pk)
[INFO] [stdout]     |         ^^^^^^^^^^ use of undeclared type `ProcResult`
[INFO] [stdout]     |
[INFO] [stdout] help: consider importing this enum
[INFO] [stdout]     |
[INFO] [stdout] 1   + use tokio_sky::ProcResult;
[INFO] [stdout]     |
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0412]: cannot find type `Pool` in this scope
[INFO] [stdout]    --> examples/batch_insert_mysql.rs:118:11
[INFO] [stdout]     |
[INFO] [stdout] 118 |     pool: Pool
[INFO] [stdout]     |           ^^^^ help: a builtin type with a similar name exists: `bool`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stderr] error: could not compile `tokio_sky` (example "pulsar_processor") due to 28 previous errors
[INFO] [stdout] error[E0412]: cannot find type `Pool` in this scope
[INFO] [stdout]    --> examples/batch_insert_mysql.rs:122:22
[INFO] [stdout]     |
[INFO] [stdout] 122 |     pub fn new(pool: Pool) -> MysqlBatcher {
[INFO] [stdout]     |                      ^^^^ help: a builtin type with a similar name exists: `bool`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0412]: cannot find type `BatcherTerminate` in this scope
[INFO] [stdout]    --> examples/batch_insert_mysql.rs:137:70
[INFO] [stdout]     |
[INFO] [stdout] 137 |     async fn handle_batch(&mut self, batch: Vec<User>) -> Result<(), BatcherTerminate<User>> {
[INFO] [stdout]     |                                                                      ^^^^^^^^^^^^^^^^ not found in this scope
[INFO] [stdout]     |
[INFO] [stdout] help: consider importing this struct
[INFO] [stdout]     |
[INFO] [stdout] 1   + use tokio_sky::BatcherTerminate;
[INFO] [stdout]     |
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0425]: cannot find value `pool` in this scope
[INFO] [stdout]    --> examples/batch_insert_mysql.rs:139:20
[INFO] [stdout]     |
[INFO] [stdout] 139 |         let conn = pool.get_conn().await.unwrap();
[INFO] [stdout]     |                    ^^^^ help: you might have meant to use the available field: `self.pool`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0412]: cannot find type `Strnig` in this scope
[INFO] [stdout]    --> examples/batch_insert_mysql.rs:157:15
[INFO] [stdout]     |
[INFO] [stdout] 157 |     fullname: Strnig
[INFO] [stdout]     |               ^^^^^^ help: a struct with a similar name exists: `String`
[INFO] [stdout]    --> /rustc/9610dfe5a9a731ced1ea4923ecbd0c57fe367898/library/alloc/src/string.rs:365:1
[INFO] [stdout]     |
[INFO] [stdout]     = note: similarly named struct `String` defined here
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0706]: functions in traits cannot be declared `async`
[INFO] [stdout]   --> examples/batch_insert_mysql.rs:76:5
[INFO] [stdout]    |
[INFO] [stdout] 76 |     async fn init(&mut self) {}
[INFO] [stdout]    |     -----^^^^^^^^^^^^^^^^^^^
[INFO] [stdout]    |     |
[INFO] [stdout]    |     `async` because of this
[INFO] [stdout]    |
[INFO] [stdout]    = note: `async` trait functions are not currently supported
[INFO] [stdout]    = note: consider using the `async-trait` crate: https://crates.io/crates/async-trait
[INFO] [stdout]    = note: see issue #91611 <https://github.com/rust-lang/rust/issues/91611> for more information
[INFO] [stdout]    = help: add `#![feature(async_fn_in_trait)]` to the crate attributes to enable
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0706]: functions in traits cannot be declared `async`
[INFO] [stdout]   --> examples/batch_insert_mysql.rs:78:5
[INFO] [stdout]    |
[INFO] [stdout] 78 |     async fn terminate(&mut self) {}
[INFO] [stdout]    |     -----^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout]    |     |
[INFO] [stdout]    |     `async` because of this
[INFO] [stdout]    |
[INFO] [stdout]    = note: `async` trait functions are not currently supported
[INFO] [stdout]    = note: consider using the `async-trait` crate: https://crates.io/crates/async-trait
[INFO] [stdout]    = note: see issue #91611 <https://github.com/rust-lang/rust/issues/91611> for more information
[INFO] [stdout]    = help: add `#![feature(async_fn_in_trait)]` to the crate attributes to enable
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stderr] error: could not compile `tokio_sky` (example "ordering_and_paritioning") due to 28 previous errors
[INFO] [stdout] error[E0706]: functions in traits cannot be declared `async`
[INFO] [stdout]   --> examples/batch_insert_mysql.rs:80:5
[INFO] [stdout]    |
[INFO] [stdout] 80 |     async fn drain(&mut self, _buffer: VecDeque<User>) {}
[INFO] [stdout]    |     -----^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout]    |     |
[INFO] [stdout]    |     `async` because of this
[INFO] [stdout]    |
[INFO] [stdout]    = note: `async` trait functions are not currently supported
[INFO] [stdout]    = note: consider using the `async-trait` crate: https://crates.io/crates/async-trait
[INFO] [stdout]    = note: see issue #91611 <https://github.com/rust-lang/rust/issues/91611> for more information
[INFO] [stdout]    = help: add `#![feature(async_fn_in_trait)]` to the crate attributes to enable
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stderr] error: could not compile `tokio_sky` (example "dynamic_batching") due to 31 previous errors
[INFO] [stdout] error[E0706]: functions in traits cannot be declared `async`
[INFO] [stdout]   --> examples/batch_insert_mysql.rs:82:5
[INFO] [stdout]    |
[INFO] [stdout] 82 |     async fn fill_buffer(&mut self, buffer_size: usize) -> Result<VecDeque<User>, Terminate> {
[INFO] [stdout]    |     -----^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout]    |     |
[INFO] [stdout]    |     `async` because of this
[INFO] [stdout]    |
[INFO] [stdout]    = note: `async` trait functions are not currently supported
[INFO] [stdout]    = note: consider using the `async-trait` crate: https://crates.io/crates/async-trait
[INFO] [stdout]    = note: see issue #91611 <https://github.com/rust-lang/rust/issues/91611> for more information
[INFO] [stdout]    = help: add `#![feature(async_fn_in_trait)]` to the crate attributes to enable
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0706]: functions in traits cannot be declared `async`
[INFO] [stdout]    --> examples/batch_insert_mysql.rs:102:5
[INFO] [stdout]     |
[INFO] [stdout] 102 |     async fn init(&mut self) {}
[INFO] [stdout]     |     -----^^^^^^^^^^^^^^^^^^^
[INFO] [stdout]     |     |
[INFO] [stdout]     |     `async` because of this
[INFO] [stdout]     |
[INFO] [stdout]     = note: `async` trait functions are not currently supported
[INFO] [stdout]     = note: consider using the `async-trait` crate: https://crates.io/crates/async-trait
[INFO] [stdout]     = note: see issue #91611 <https://github.com/rust-lang/rust/issues/91611> for more information
[INFO] [stdout]     = help: add `#![feature(async_fn_in_trait)]` to the crate attributes to enable
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0706]: functions in traits cannot be declared `async`
[INFO] [stdout]    --> examples/batch_insert_mysql.rs:103:5
[INFO] [stdout]     |
[INFO] [stdout] 103 |     async fn terminate(&mut self) {}
[INFO] [stdout]     |     -----^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout]     |     |
[INFO] [stdout]     |     `async` because of this
[INFO] [stdout]     |
[INFO] [stdout]     = note: `async` trait functions are not currently supported
[INFO] [stdout]     = note: consider using the `async-trait` crate: https://crates.io/crates/async-trait
[INFO] [stdout]     = note: see issue #91611 <https://github.com/rust-lang/rust/issues/91611> for more information
[INFO] [stdout]     = help: add `#![feature(async_fn_in_trait)]` to the crate attributes to enable
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0706]: functions in traits cannot be declared `async`
[INFO] [stdout]    --> examples/batch_insert_mysql.rs:105:5
[INFO] [stdout]     |
[INFO] [stdout] 105 |     async fn handle_message(&mut self, msg: User) ->  ProcResult<User> {
[INFO] [stdout]     |     -----^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout]     |     |
[INFO] [stdout]     |     `async` because of this
[INFO] [stdout]     |
[INFO] [stdout]     = note: `async` trait functions are not currently supported
[INFO] [stdout]     = note: consider using the `async-trait` crate: https://crates.io/crates/async-trait
[INFO] [stdout]     = note: see issue #91611 <https://github.com/rust-lang/rust/issues/91611> for more information
[INFO] [stdout]     = help: add `#![feature(async_fn_in_trait)]` to the crate attributes to enable
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0706]: functions in traits cannot be declared `async`
[INFO] [stdout]    --> examples/batch_insert_mysql.rs:130:5
[INFO] [stdout]     |
[INFO] [stdout] 130 |     async fn init(&mut self) { }
[INFO] [stdout]     |     -----^^^^^^^^^^^^^^^^^^^
[INFO] [stdout]     |     |
[INFO] [stdout]     |     `async` because of this
[INFO] [stdout]     |
[INFO] [stdout]     = note: `async` trait functions are not currently supported
[INFO] [stdout]     = note: consider using the `async-trait` crate: https://crates.io/crates/async-trait
[INFO] [stdout]     = note: see issue #91611 <https://github.com/rust-lang/rust/issues/91611> for more information
[INFO] [stdout]     = help: add `#![feature(async_fn_in_trait)]` to the crate attributes to enable
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0706]: functions in traits cannot be declared `async`
[INFO] [stdout]    --> examples/batch_insert_mysql.rs:132:5
[INFO] [stdout]     |
[INFO] [stdout] 132 |     async fn terminate(&mut self) { }
[INFO] [stdout]     |     -----^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout]     |     |
[INFO] [stdout]     |     `async` because of this
[INFO] [stdout]     |
[INFO] [stdout]     = note: `async` trait functions are not currently supported
[INFO] [stdout]     = note: consider using the `async-trait` crate: https://crates.io/crates/async-trait
[INFO] [stdout]     = note: see issue #91611 <https://github.com/rust-lang/rust/issues/91611> for more information
[INFO] [stdout]     = help: add `#![feature(async_fn_in_trait)]` to the crate attributes to enable
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0706]: functions in traits cannot be declared `async`
[INFO] [stdout]    --> examples/batch_insert_mysql.rs:134:5
[INFO] [stdout]     |
[INFO] [stdout] 134 |     async fn drain(&mut self, batch: Vec<User>) { }
[INFO] [stdout]     |     -----^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout]     |     |
[INFO] [stdout]     |     `async` because of this
[INFO] [stdout]     |
[INFO] [stdout]     = note: `async` trait functions are not currently supported
[INFO] [stdout]     = note: consider using the `async-trait` crate: https://crates.io/crates/async-trait
[INFO] [stdout]     = note: see issue #91611 <https://github.com/rust-lang/rust/issues/91611> for more information
[INFO] [stdout]     = help: add `#![feature(async_fn_in_trait)]` to the crate attributes to enable
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0706]: functions in traits cannot be declared `async`
[INFO] [stdout]    --> examples/batch_insert_mysql.rs:137:5
[INFO] [stdout]     |
[INFO] [stdout] 137 |     async fn handle_batch(&mut self, batch: Vec<User>) -> Result<(), BatcherTerminate<User>> {
[INFO] [stdout]     |     -----^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout]     |     |
[INFO] [stdout]     |     `async` because of this
[INFO] [stdout]     |
[INFO] [stdout]     = note: `async` trait functions are not currently supported
[INFO] [stdout]     = note: consider using the `async-trait` crate: https://crates.io/crates/async-trait
[INFO] [stdout]     = note: see issue #91611 <https://github.com/rust-lang/rust/issues/91611> for more information
[INFO] [stdout]     = help: add `#![feature(async_fn_in_trait)]` to the crate attributes to enable
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0425]: cannot find function `run_topology_1_with_batcher` in this scope
[INFO] [stdout]   --> examples/batch_insert_mysql.rs:40:17
[INFO] [stdout]    |
[INFO] [stdout] 40 |                 run_topology_1_with_batcher(
[INFO] [stdout]    |                 ^^^^^^^^^^^^^^^^^^^^^^^^^^^ not found in this scope
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error: aborting due to 33 previous errors
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] Some errors have detailed explanations: E0405, E0412, E0425, E0433, E0706.
[INFO] [stdout] 
[INFO] [stdout] For more information about an error, try `rustc --explain E0405`.
[INFO] [stdout] 
[INFO] [stderr] error: could not compile `tokio_sky` (example "batch_insert_mysql") due to 34 previous errors
[INFO] running `Command { std: "docker" "inspect" "62d159b0ba12fbe8c5e03852b0110d03dbf5aa94222d0915e57990d6ff2894cc", kill_on_drop: false }`
[INFO] running `Command { std: "docker" "rm" "-f" "62d159b0ba12fbe8c5e03852b0110d03dbf5aa94222d0915e57990d6ff2894cc", kill_on_drop: false }`
[INFO] [stdout] 62d159b0ba12fbe8c5e03852b0110d03dbf5aa94222d0915e57990d6ff2894cc
